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

fetchFromScheduledTaskQueue() — netty Function Reference

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

Function java CommonUtil Concurrent calls 1

Entity Profile

Dependency Diagram

graph TD
  f38c8417_5f23_fda3_783c_4c3641bb459a["fetchFromScheduledTaskQueue()"]
  d3e4d355_bb72_2545_e37d_dc0891709c08["AbstractScheduledEventExecutor"]
  f38c8417_5f23_fda3_783c_4c3641bb459a -->|defined in| d3e4d355_bb72_2545_e37d_dc0891709c08
  1bfb3315_93ae_ff94_32ad_7e00bc671264["getCurrentTimeNanos()"]
  f38c8417_5f23_fda3_783c_4c3641bb459a -->|calls| 1bfb3315_93ae_ff94_32ad_7e00bc671264
  style f38c8417_5f23_fda3_783c_4c3641bb459a fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

common/src/main/java/io/netty/util/concurrent/AbstractScheduledEventExecutor.java lines 187–208

    protected boolean fetchFromScheduledTaskQueue(Queue<Runnable> taskQueue) {
        assert inEventLoop();
        Objects.requireNonNull(taskQueue, "taskQueue");
        if (scheduledTaskQueue == null || scheduledTaskQueue.isEmpty()) {
            return true;
        }
        long nanoTime = getCurrentTimeNanos();
        for (;;) {
            ScheduledFutureTask scheduledTask = (ScheduledFutureTask) pollScheduledTask(nanoTime);
            if (scheduledTask == null) {
                return true;
            }
            if (scheduledTask.isCancelled()) {
                continue;
            }
            if (!taskQueue.offer(scheduledTask)) {
                // No space left in the task queue add it back to the scheduledTaskQueue so we pick it up again.
                scheduledTaskQueue.add(scheduledTask);
                return false;
            }
        }
    }

Domain

Subdomains

Defined In

Calls

Source

Frequently Asked Questions

What does fetchFromScheduledTaskQueue() do?
fetchFromScheduledTaskQueue() is a function in the netty codebase, defined in common/src/main/java/io/netty/util/concurrent/AbstractScheduledEventExecutor.java.
Where is fetchFromScheduledTaskQueue() defined?
fetchFromScheduledTaskQueue() is defined in common/src/main/java/io/netty/util/concurrent/AbstractScheduledEventExecutor.java at line 187.
What does fetchFromScheduledTaskQueue() call?
fetchFromScheduledTaskQueue() calls 1 function(s): getCurrentTimeNanos.

Analyze Your Own Codebase

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

Try Supermodel Free