testTakeTask() — netty Function Reference

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

Function java Buffer Search calls 1

Entity Profile

Buffer→ Search→ testTakeTask() — netty Function Reference

Dependency Diagram

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

Relationship Graph

Source Code

common/src/test/java/io/netty/util/concurrent/GlobalEventExecutorTest.java lines 113–133

    @Test
    @Timeout(value = 5000, unit = TimeUnit.MILLISECONDS)
    public void testTakeTask() throws Exception {
        //add task
        TestRunnable beforeTask = new TestRunnable(0);
        e.execute(beforeTask);

        //add scheduled task
        TestRunnable scheduledTask = new TestRunnable(0);
        ScheduledFuture<?> f = e.schedule(scheduledTask , 1500, TimeUnit.MILLISECONDS);

        //add task
        TestRunnable afterTask = new TestRunnable(0);
        e.execute(afterTask);

        f.sync();

        assertTrue(beforeTask.ran.get());
        assertTrue(scheduledTask.ran.get());
        assertTrue(afterTask.ran.get());
    }