netty Architecture Docs
Home / Function/ runTaskQueue() — netty Function Reference

runTaskQueue() — netty Function Reference

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

Function java Buffer Telemetry calls 2 called by 2

Entity Profile

Dependency Diagram

graph TD
  f449fa2c_e258_1aba_423a_5369445ba398["runTaskQueue()"]
  379a0f3e_d35d_8054_6f12_48a2cfebefb5["FixedChannelPool"]
  f449fa2c_e258_1aba_423a_5369445ba398 -->|defined in| 379a0f3e_d35d_8054_6f12_48a2cfebefb5
  21d08587_1275_d708_de67_34ff59c3d946["decrementAndRunTaskQueue()"]
  21d08587_1275_d708_de67_34ff59c3d946 -->|calls| f449fa2c_e258_1aba_423a_5369445ba398
  a0e3ca45_7007_bd76_d79f_81a640f79d24["operationComplete()"]
  a0e3ca45_7007_bd76_d79f_81a640f79d24 -->|calls| f449fa2c_e258_1aba_423a_5369445ba398
  0838d3b3_52a9_65c1_0d21_2ababab8d237["acquired()"]
  f449fa2c_e258_1aba_423a_5369445ba398 -->|calls| 0838d3b3_52a9_65c1_0d21_2ababab8d237
  1d51fd53_2c69_0470_07c7_4631383a891c["acquire()"]
  f449fa2c_e258_1aba_423a_5369445ba398 -->|calls| 1d51fd53_2c69_0470_07c7_4631383a891c
  style f449fa2c_e258_1aba_423a_5369445ba398 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport/src/main/java/io/netty/channel/pool/FixedChannelPool.java lines 335–357

    private void runTaskQueue() {
        while (acquiredChannelCount.get() < maxConnections) {
            AcquireTask task = pendingAcquireQueue.poll();
            if (task == null) {
                break;
            }

            // Cancel the timeout if one was scheduled
            ScheduledFuture<?> timeoutFuture = task.timeoutFuture;
            if (timeoutFuture != null) {
                timeoutFuture.cancel(false);
            }

            --pendingAcquireCount;
            task.acquired();

            super.acquire(task.promise);
        }

        // We should never have a negative value.
        assert pendingAcquireCount >= 0;
        assert acquiredChannelCount.get() >= 0;
    }

Domain

Subdomains

Defined In

Calls

Called By

Source

Frequently Asked Questions

What does runTaskQueue() do?
runTaskQueue() is a function in the netty codebase, defined in transport/src/main/java/io/netty/channel/pool/FixedChannelPool.java.
Where is runTaskQueue() defined?
runTaskQueue() is defined in transport/src/main/java/io/netty/channel/pool/FixedChannelPool.java at line 335.
What does runTaskQueue() call?
runTaskQueue() calls 2 function(s): acquire, acquired.
What calls runTaskQueue()?
runTaskQueue() is called by 2 function(s): decrementAndRunTaskQueue, operationComplete.

Analyze Your Own Codebase

Get architecture documentation, dependency graphs, and domain analysis for your codebase in minutes.

Try Supermodel Free