newMpscQueue() — netty Function Reference

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

Function java CommonUtil Internal calls 2 called by 1

Entity Profile

CommonUtil→ Internal→ newMpscQueue() — netty Function Reference

Dependency Diagram

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

Relationship Graph

Source Code

common/src/main/java/io/netty/util/internal/PlatformDependent.java lines 1263–1269

        static <T> Queue<T> newMpscQueue(final int maxCapacity) {
            // Calculate the max capacity which can not be bigger than MAX_ALLOWED_MPSC_CAPACITY.
            // This is forced by the MpscChunkedArrayQueue implementation as will try to round it
            // up to the next power of two and so will overflow otherwise.
            final int capacity = max(min(maxCapacity, MAX_ALLOWED_MPSC_CAPACITY), MIN_MAX_MPSC_CAPACITY);
            return newChunkedMpscQueue(MPSC_CHUNK_SIZE, capacity);
        }