shutdownAfterStart() — netty Function Reference

Architecture documentation for the shutdownAfterStart() function in SingleThreadEventLoopTest.java from the netty codebase.

Function java Buffer Search calls 2

Entity Profile

Buffer→ Search→ shutdownAfterStart() — netty Function Reference

Dependency Diagram

graph TD
  357fbc91_cbc8_821d_117a_00679a2dc4a6["shutdownAfterStart()"]
  42a05bb6_77d1_5163_f1de_dc06e1ae82b0["SingleThreadEventLoopTest"]
  357fbc91_cbc8_821d_117a_00679a2dc4a6 -->|defined in| 42a05bb6_77d1_5163_f1de_dc06e1ae82b0
  46833dd9_b315_29c3_5ea4_b78bade68a99["assertRejection()"]
  357fbc91_cbc8_821d_117a_00679a2dc4a6 -->|calls| 46833dd9_b315_29c3_5ea4_b78bade68a99
  b79014df_fa4d_f5ee_0fee_b9e3906bd3e9["run()"]
  357fbc91_cbc8_821d_117a_00679a2dc4a6 -->|calls| b79014df_fa4d_f5ee_0fee_b9e3906bd3e9
  style 357fbc91_cbc8_821d_117a_00679a2dc4a6 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport/src/test/java/io/netty/channel/SingleThreadEventLoopTest.java lines 113–137

    @Test
    @SuppressWarnings("deprecation")
    public void shutdownAfterStart() throws Exception {
        final CountDownLatch latch = new CountDownLatch(1);
        loopA.execute(new Runnable() {
            @Override
            public void run() {
                latch.countDown();
            }
        });

        // Wait for the event loop thread to start.
        latch.await();

        // Request the event loop thread to stop.
        loopA.shutdown();
        assertRejection(loopA);

        assertTrue(loopA.isShutdown());

        // Wait until the event loop is terminated.
        while (!loopA.isTerminated()) {
            loopA.awaitTermination(1, TimeUnit.DAYS);
        }
    }