testThreadEventExecutorMap() — netty Function Reference

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

Function java Buffer Telemetry calls 1

Entity Profile

Buffer→ Telemetry→ testThreadEventExecutorMap() — netty Function Reference

Dependency Diagram

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

Relationship Graph

Source Code

transport/src/test/java/io/netty/channel/ManualIoEventLoopTest.java lines 125–141

    @Test
    public void testThreadEventExecutorMap() throws Exception {
        final BlockingQueue<EventExecutor> queue = new LinkedBlockingQueue<>();
        Semaphore semaphore = new Semaphore(0);
        ManualIoEventLoop eventLoop = new ManualIoEventLoop(Thread.currentThread(), executor ->
                new TestIoHandler(semaphore));
        assertNull(ThreadExecutorMap.currentExecutor());
        eventLoop.execute(() -> queue.offer(ThreadExecutorMap.currentExecutor()));
        assertEquals(1, eventLoop.runNow());
        assertSame(eventLoop, queue.take());
        eventLoop.shutdown();

        while (!eventLoop.isTerminated()) {
            eventLoop.runNow();
        }
        eventLoop.terminationFuture().sync();
    }