fetchFromScheduledTaskQueue() — netty Function Reference

Architecture documentation for the fetchFromScheduledTaskQueue() function in GlobalEventExecutor.java from the netty codebase.

Function java CommonUtil Concurrent called by 1

Entity Profile

CommonUtil→ Concurrent→ fetchFromScheduledTaskQueue() — netty Function Reference

Dependency Diagram

graph TD
  411270ac_1d47_f717_3023_68be625f3871["fetchFromScheduledTaskQueue()"]
  408381e8_b0ab_c53d_3b6c_8d8a15aaa884["GlobalEventExecutor"]
  411270ac_1d47_f717_3023_68be625f3871 -->|defined in| 408381e8_b0ab_c53d_3b6c_8d8a15aaa884
  d2063834_69ba_5d89_1375_f14b3f8cba35["Runnable()"]
  d2063834_69ba_5d89_1375_f14b3f8cba35 -->|calls| 411270ac_1d47_f717_3023_68be625f3871
  style 411270ac_1d47_f717_3023_68be625f3871 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

common/src/main/java/io/netty/util/concurrent/GlobalEventExecutor.java lines 140–149

    private void fetchFromScheduledTaskQueue() {
        long nanoTime = getCurrentTimeNanos();
        ScheduledFutureTask scheduledTask;
        while ((scheduledTask = (ScheduledFutureTask) pollScheduledTask(nanoTime)) != null) {
            if (scheduledTask.isCancelled()) {
                continue;
            }
            taskQueue.add(scheduledTask);
        }
    }