newFixedMpscQueue() — netty Function Reference

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

Function java CommonUtil Internal calls 1

Entity Profile

CommonUtil→ Internal→ newFixedMpscQueue() — netty Function Reference

Dependency Diagram

graph TD
  eed99cc3_7862_0976_daca_8d6267c8c4e6["newFixedMpscQueue()"]
  2e66d079_807f_6785_864f_73ab09fbc515["PlatformDependent"]
  eed99cc3_7862_0976_daca_8d6267c8c4e6 -->|defined in| 2e66d079_807f_6785_864f_73ab09fbc515
  f9f97c70_723b_fe44_1e76_e4c49b6d6c61["hasUnsafe()"]
  eed99cc3_7862_0976_daca_8d6267c8c4e6 -->|calls| f9f97c70_723b_fe44_1e76_e4c49b6d6c61
  style eed99cc3_7862_0976_daca_8d6267c8c4e6 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

common/src/main/java/io/netty/util/internal/PlatformDependent.java lines 1320–1322

    public static <T> Queue<T> newFixedMpscQueue(int capacity) {
        return hasUnsafe() ? new MpscArrayQueue<T>(capacity) : new MpscAtomicArrayQueue<T>(capacity);
    }