runAllTasks() — netty Function Reference

Architecture documentation for the runAllTasks() function in SingleThreadEventExecutor.java from the netty codebase.

Function java CommonUtil Concurrent calls 4 called by 1

Entity Profile

CommonUtil→ Concurrent→ runAllTasks() — netty Function Reference

Dependency Diagram

graph TD
  aae2a1cf_9734_69c3_1254_17f62df7beab["runAllTasks()"]
  c9189467_acbc_07ea_3a8c_fecfe22ec122["SingleThreadEventExecutor"]
  aae2a1cf_9734_69c3_1254_17f62df7beab -->|defined in| c9189467_acbc_07ea_3a8c_fecfe22ec122
  2fbe8756_76da_a86e_960c_bf11273a6375["confirmShutdown()"]
  2fbe8756_76da_a86e_960c_bf11273a6375 -->|calls| aae2a1cf_9734_69c3_1254_17f62df7beab
  957fd634_92d8_ad7a_8d3f_c6d9e5d7ee2a["inEventLoop()"]
  aae2a1cf_9734_69c3_1254_17f62df7beab -->|calls| 957fd634_92d8_ad7a_8d3f_c6d9e5d7ee2a
  736e6f77_4f80_844d_7e6b_1a1ec1cd6dc6["fetchFromScheduledTaskQueue()"]
  aae2a1cf_9734_69c3_1254_17f62df7beab -->|calls| 736e6f77_4f80_844d_7e6b_1a1ec1cd6dc6
  994aa2a4_0128_e4c9_7f90_7004ebce34ff["runAllTasksFrom()"]
  aae2a1cf_9734_69c3_1254_17f62df7beab -->|calls| 994aa2a4_0128_e4c9_7f90_7004ebce34ff
  74baded2_7ae5_b964_9529_61a1e7a6c626["afterRunningAllTasks()"]
  aae2a1cf_9734_69c3_1254_17f62df7beab -->|calls| 74baded2_7ae5_b964_9529_61a1e7a6c626
  style aae2a1cf_9734_69c3_1254_17f62df7beab fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

common/src/main/java/io/netty/util/concurrent/SingleThreadEventExecutor.java lines 430–447

    protected boolean runAllTasks() {
        assert inEventLoop();
        boolean fetchedAll;
        boolean ranAtLeastOne = false;

        do {
            fetchedAll = fetchFromScheduledTaskQueue(taskQueue);
            if (runAllTasksFrom(taskQueue)) {
                ranAtLeastOne = true;
            }
        } while (!fetchedAll); // keep on processing until we fetched all scheduled tasks.

        if (ranAtLeastOne) {
            lastExecutionTime = getCurrentTimeNanos();
        }
        afterRunningAllTasks();
        return ranAtLeastOne;
    }