testExecutionOnTaskExecutor() — netty Function Reference

Architecture documentation for the testExecutionOnTaskExecutor() function in HashedWheelTimerTest.java from the netty codebase.

Function java Buffer Search calls 1

Entity Profile

Buffer→ Search→ testExecutionOnTaskExecutor() — netty Function Reference

Dependency Diagram

graph TD
  05850959_622a_2869_eb39_466a9901789c["testExecutionOnTaskExecutor()"]
  00b49e45_9607_bed0_2d5f_fd3bdc9b959f["HashedWheelTimerTest"]
  05850959_622a_2869_eb39_466a9901789c -->|defined in| 00b49e45_9607_bed0_2d5f_fd3bdc9b959f
  c46ba577_0225_1b73_1919_e2b7cb5a1767["TimerTask()"]
  05850959_622a_2869_eb39_466a9901789c -->|calls| c46ba577_0225_1b73_1919_e2b7cb5a1767
  style 05850959_622a_2869_eb39_466a9901789c fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

common/src/test/java/io/netty/util/HashedWheelTimerTest.java lines 169–197

    @Test
    public void testExecutionOnTaskExecutor() throws InterruptedException {
        int timeout = 10;

        final CountDownLatch latch = new CountDownLatch(1);
        final CountDownLatch timeoutLatch = new CountDownLatch(1);
        Executor executor = new Executor() {
            @Override
            public void execute(Runnable command) {
                try {
                    command.run();
                } finally {
                    latch.countDown();
                }
            }
        };
        final HashedWheelTimer timer = new HashedWheelTimer(Executors.defaultThreadFactory(), 100,
                TimeUnit.MILLISECONDS, 32, true, 2, executor);
        timer.newTimeout(new TimerTask() {
            @Override
            public void run(final Timeout timeout) throws Exception {
                timeoutLatch.countDown();
            }
        }, timeout, TimeUnit.MILLISECONDS);

        latch.await();
        timeoutLatch.await();
        timer.stop();
    }