testDelayOwningThread() — netty Function Reference

Architecture documentation for the testDelayOwningThread() function in ManualIoEventLoopTest.java from the netty codebase.

Function java Buffer Telemetry calls 1

Entity Profile

Buffer→ Telemetry→ testDelayOwningThread() — netty Function Reference

Dependency Diagram

graph TD
  158dd839_f317_c7ee_51df_f48dc0c5c11f["testDelayOwningThread()"]
  7f1091cc_a8b6_0293_92ad_d94222ae6482["ManualIoEventLoopTest"]
  158dd839_f317_c7ee_51df_f48dc0c5c11f -->|defined in| 7f1091cc_a8b6_0293_92ad_d94222ae6482
  3bf16ebe_cf8d_923f_9559_397075f9b2a1["TestIoHandler()"]
  158dd839_f317_c7ee_51df_f48dc0c5c11f -->|calls| 3bf16ebe_cf8d_923f_9559_397075f9b2a1
  style 158dd839_f317_c7ee_51df_f48dc0c5c11f fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport/src/test/java/io/netty/channel/ManualIoEventLoopTest.java lines 223–249

    @Test
    public void testDelayOwningThread() throws ExecutionException, InterruptedException {
        Semaphore semaphore = new Semaphore(0);
        ManualIoEventLoop eventLoop = new ManualIoEventLoop(null, executor ->
                new TestIoHandler(semaphore));
        Thread thread = new Thread(() -> {
            eventLoop.setOwningThread(Thread.currentThread());
            assertTrue(eventLoop.inEventLoop());
            while (!eventLoop.isTerminated()) {
                eventLoop.runNow();
            }
        });

        assertFalse(eventLoop.inEventLoop());

        CompletableFuture<Void> cf = new CompletableFuture<>();
        eventLoop.execute(() -> {
            assertTrue(eventLoop.inEventLoop());
            cf.complete(null);
        });

        thread.start();
        cf.get();

        eventLoop.shutdownGracefully();
        thread.join();
    }