decrementAndRunTaskQueue() — netty Function Reference

Architecture documentation for the decrementAndRunTaskQueue() function in FixedChannelPool.java from the netty codebase.

Function java Buffer Allocators calls 1 called by 2

Entity Profile

Buffer→ Allocators→ decrementAndRunTaskQueue() — netty Function Reference

Dependency Diagram

graph TD
  21d08587_1275_d708_de67_34ff59c3d946["decrementAndRunTaskQueue()"]
  379a0f3e_d35d_8054_6f12_48a2cfebefb5["FixedChannelPool"]
  21d08587_1275_d708_de67_34ff59c3d946 -->|defined in| 379a0f3e_d35d_8054_6f12_48a2cfebefb5
  315745f1_dcf7_b5f2_a7bf_6256c54b99a0["release()"]
  315745f1_dcf7_b5f2_a7bf_6256c54b99a0 -->|calls| 21d08587_1275_d708_de67_34ff59c3d946
  a0e3ca45_7007_bd76_d79f_81a640f79d24["operationComplete()"]
  a0e3ca45_7007_bd76_d79f_81a640f79d24 -->|calls| 21d08587_1275_d708_de67_34ff59c3d946
  f449fa2c_e258_1aba_423a_5369445ba398["runTaskQueue()"]
  21d08587_1275_d708_de67_34ff59c3d946 -->|calls| f449fa2c_e258_1aba_423a_5369445ba398
  style 21d08587_1275_d708_de67_34ff59c3d946 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport/src/main/java/io/netty/channel/pool/FixedChannelPool.java lines 323–333

    private void decrementAndRunTaskQueue() {
        // We should never have a negative value.
        int currentCount = acquiredChannelCount.decrementAndGet();
        assert currentCount >= 0;

        // Run the pending acquire tasks before notify the original promise so if the user would
        // try to acquire again from the ChannelFutureListener and the pendingAcquireCount is >=
        // maxPendingAcquires we may be able to run some pending tasks first and so allow to add
        // more.
        runTaskQueue();
    }