leastUsedArena() — netty Function Reference

Architecture documentation for the leastUsedArena() function in PooledByteBufAllocator.java from the netty codebase.

Function java Buffer Telemetry called by 1

Entity Profile

Buffer→ Telemetry→ leastUsedArena() — netty Function Reference

Dependency Diagram

graph TD
  3a397dda_86fd_1377_4f30_948b9bdc738f["leastUsedArena()"]
  9ad685de_b1d1_da3f_7071_bd6a25943246["PoolThreadLocalCache"]
  3a397dda_86fd_1377_4f30_948b9bdc738f -->|defined in| 9ad685de_b1d1_da3f_7071_bd6a25943246
  f96ecd0d_de3e_5b33_3b04_dafb79f28944["PoolThreadCache()"]
  f96ecd0d_de3e_5b33_3b04_dafb79f28944 -->|calls| 3a397dda_86fd_1377_4f30_948b9bdc738f
  style 3a397dda_86fd_1377_4f30_948b9bdc738f fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

buffer/src/main/java/io/netty/buffer/PooledByteBufAllocator.java lines 560–579

        private <T> PoolArena<T> leastUsedArena(PoolArena<T>[] arenas) {
            if (arenas == null || arenas.length == 0) {
                return null;
            }

            PoolArena<T> minArena = arenas[0];
            //optimized
            //If it is the first execution, directly return minarena and reduce the number of for loop comparisons below
            if (minArena.numThreadCaches.get() == CACHE_NOT_USED) {
                return minArena;
            }
            for (int i = 1; i < arenas.length; i++) {
                PoolArena<T> arena = arenas[i];
                if (arena.numThreadCaches.get() < minArena.numThreadCaches.get()) {
                    minArena = arena;
                }
            }

            return minArena;
        }