runAllTasksFrom() — netty Function Reference

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

Function java CommonUtil Concurrent called by 1

Entity Profile

CommonUtil→ Concurrent→ runAllTasksFrom() — netty Function Reference

Dependency Diagram

graph TD
  994aa2a4_0128_e4c9_7f90_7004ebce34ff["runAllTasksFrom()"]
  c9189467_acbc_07ea_3a8c_fecfe22ec122["SingleThreadEventExecutor"]
  994aa2a4_0128_e4c9_7f90_7004ebce34ff -->|defined in| c9189467_acbc_07ea_3a8c_fecfe22ec122
  aae2a1cf_9734_69c3_1254_17f62df7beab["runAllTasks()"]
  aae2a1cf_9734_69c3_1254_17f62df7beab -->|calls| 994aa2a4_0128_e4c9_7f90_7004ebce34ff
  style 994aa2a4_0128_e4c9_7f90_7004ebce34ff fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

common/src/main/java/io/netty/util/concurrent/SingleThreadEventExecutor.java lines 482–494

    protected final boolean runAllTasksFrom(Queue<Runnable> taskQueue) {
        Runnable task = pollTaskFrom(taskQueue);
        if (task == null) {
            return false;
        }
        for (;;) {
            safeExecute(task);
            task = pollTaskFrom(taskQueue);
            if (task == null) {
                return true;
            }
        }
    }