newChunkedMpscQueue() — netty Function Reference

Architecture documentation for the newChunkedMpscQueue() function in PlatformDependent.java from the netty codebase.

Function java CommonUtil Internal called by 2

Entity Profile

CommonUtil→ Internal→ newChunkedMpscQueue() — netty Function Reference

Dependency Diagram

graph TD
  2c56bdf1_39e8_a02b_7bb7_2e17c47dfe88["newChunkedMpscQueue()"]
  64a7fae9_2520_5d33_c8bb_078ffd09ede3["Mpsc"]
  2c56bdf1_39e8_a02b_7bb7_2e17c47dfe88 -->|defined in| 64a7fae9_2520_5d33_c8bb_078ffd09ede3
  4373c477_ad04_6eff_662b_2a896d34d457["newMpscQueue()"]
  4373c477_ad04_6eff_662b_2a896d34d457 -->|calls| 2c56bdf1_39e8_a02b_7bb7_2e17c47dfe88
  2959ba5c_232d_fa19_0dd5_61352fd9a44f["newMpscQueue()"]
  2959ba5c_232d_fa19_0dd5_61352fd9a44f -->|calls| 2c56bdf1_39e8_a02b_7bb7_2e17c47dfe88
  style 2c56bdf1_39e8_a02b_7bb7_2e17c47dfe88 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

common/src/main/java/io/netty/util/internal/PlatformDependent.java lines 1271–1274

        static <T> Queue<T> newChunkedMpscQueue(final int chunkSize, final int capacity) {
            return USE_MPSC_CHUNKED_ARRAY_QUEUE ? new MpscChunkedArrayQueue<T>(chunkSize, capacity)
                    : new MpscChunkedAtomicArrayQueue<T>(chunkSize, capacity);
        }