run() — netty Function Reference

Architecture documentation for the run() function in MultiThreadIoEventLoopGroupTest.java from the netty codebase.

Function java Buffer Telemetry called by 1

Entity Profile

Buffer→ Telemetry→ run() — netty Function Reference

Dependency Diagram

graph TD
  9830fcb8_e5b5_cc90_d277_35c9a3443446["run()"]
  58be7942_44d1_cd6e_f39f_cad5938b2ce3["TestableIoEventLoop"]
  9830fcb8_e5b5_cc90_d277_35c9a3443446 -->|defined in| 58be7942_44d1_cd6e_f39f_cad5938b2ce3
  bf26b1d1_cf9e_11e8_61db_9c1f32fbbcbf["IoHandler()"]
  bf26b1d1_cf9e_11e8_61db_9c1f32fbbcbf -->|calls| 9830fcb8_e5b5_cc90_d277_35c9a3443446
  style 9830fcb8_e5b5_cc90_d277_35c9a3443446 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport/src/test/java/io/netty/channel/MultiThreadIoEventLoopGroupTest.java lines 104–121

        @Override
        protected void run() {
            do {
                if (simulateWorkload.get()) {
                    try {
                        Thread.sleep(100);
                    } catch (InterruptedException e) {
                        Thread.currentThread().interrupt();
                    }
                    reportActiveIoTime(TimeUnit.MILLISECONDS.toNanos(100));
                } else {
                    Runnable task = takeTask();
                    if (task != null) {
                        safeExecute(task);
                    }
                }
            } while (!confirmShutdown() && !canSuspend());
        }