testTakeTask() — netty Function Reference

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

Function java Buffer Telemetry calls 2

Entity Profile

Buffer→ Telemetry→ testTakeTask() — netty Function Reference

Dependency Diagram

graph TD
  4cb99e75_94eb_16c7_ad9f_a52ee70a394d["testTakeTask()"]
  bbf4ea8d_698f_542a_1559_437b1b237a04["SingleThreadEventExecutorTest"]
  4cb99e75_94eb_16c7_ad9f_a52ee70a394d -->|defined in| bbf4ea8d_698f_542a_1559_437b1b237a04
  9af9390f_cdb2_0d1d_41be_9213e44c712d["TestRunnable()"]
  4cb99e75_94eb_16c7_ad9f_a52ee70a394d -->|calls| 9af9390f_cdb2_0d1d_41be_9213e44c712d
  d1474077_6d3a_87c2_2d11_070af739005b["run()"]
  4cb99e75_94eb_16c7_ad9f_a52ee70a394d -->|calls| d1474077_6d3a_87c2_2d11_070af739005b
  style 4cb99e75_94eb_16c7_ad9f_a52ee70a394d fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

common/src/test/java/io/netty/util/concurrent/SingleThreadEventExecutorTest.java lines 551–585

    @Test
    @Timeout(value = 5000, unit = TimeUnit.MILLISECONDS)
    public void testTakeTask() throws Exception {
        final SingleThreadEventExecutor executor =
                new SingleThreadEventExecutor(null, Executors.defaultThreadFactory(), true) {
            @Override
            protected void run() {
                while (!confirmShutdown()) {
                    Runnable task = takeTask();
                    if (task != null) {
                        task.run();
                    }
                }
            }
        };

        //add task
        TestRunnable beforeTask = new TestRunnable();
        executor.execute(beforeTask);

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

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

        f.sync();

        assertTrue(beforeTask.ran.get());
        assertTrue(scheduledTask.ran.get());
        assertTrue(afterTask.ran.get());
        executor.shutdownGracefully(0, 0, TimeUnit.MILLISECONDS).syncUninterruptibly();
    }