testScheduledTasks() — netty Function Reference

Architecture documentation for the testScheduledTasks() function in GlobalEventExecutorTest.java from the netty codebase.

Function java Buffer Search calls 1

Entity Profile

Buffer→ Search→ testScheduledTasks() — netty Function Reference

Dependency Diagram

graph TD
  f52cce85_0dbd_2013_8c9d_bcb4404863a2["testScheduledTasks()"]
  f5a88566_416e_7970_655d_74968e21adb8["GlobalEventExecutorTest"]
  f52cce85_0dbd_2013_8c9d_bcb4404863a2 -->|defined in| f5a88566_416e_7970_655d_74968e21adb8
  c3766603_5691_d3ab_0426_40fc291e9fe8["TestRunnable()"]
  f52cce85_0dbd_2013_8c9d_bcb4404863a2 -->|calls| c3766603_5691_d3ab_0426_40fc291e9fe8
  style f52cce85_0dbd_2013_8c9d_bcb4404863a2 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

common/src/test/java/io/netty/util/concurrent/GlobalEventExecutorTest.java lines 73–87

    @Test
    @Timeout(value = 5000, unit = TimeUnit.MILLISECONDS)
    public void testScheduledTasks() throws Exception {
        TestRunnable task = new TestRunnable(0);
        ScheduledFuture<?> f = e.schedule(task, 1500, TimeUnit.MILLISECONDS);
        f.sync();
        assertTrue(task.ran.get());

        // Ensure the thread is still running.
        Thread thread = e.thread;
        assertNotNull(thread);
        assertTrue(thread.isAlive());

        thread.join();
    }