testAutomaticStartStop() — netty Function Reference

Architecture documentation for the testAutomaticStartStop() function in GlobalEventExecutorTest.java from the netty codebase.

Function java Buffer Telemetry calls 1

Entity Profile

Buffer→ Telemetry→ testAutomaticStartStop() — netty Function Reference

Dependency Diagram

graph TD
  18fde39f_bab9_995e_d922_cf54eb7ed932["testAutomaticStartStop()"]
  f5a88566_416e_7970_655d_74968e21adb8["GlobalEventExecutorTest"]
  18fde39f_bab9_995e_d922_cf54eb7ed932 -->|defined in| f5a88566_416e_7970_655d_74968e21adb8
  c3766603_5691_d3ab_0426_40fc291e9fe8["TestRunnable()"]
  18fde39f_bab9_995e_d922_cf54eb7ed932 -->|calls| c3766603_5691_d3ab_0426_40fc291e9fe8
  style 18fde39f_bab9_995e_d922_cf54eb7ed932 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

common/src/test/java/io/netty/util/concurrent/GlobalEventExecutorTest.java lines 48–71

    @Test
    @Timeout(value = 5000, unit = TimeUnit.MILLISECONDS)
    public void testAutomaticStartStop() throws Exception {
        final TestRunnable task = new TestRunnable(500);
        e.execute(task);

        // Ensure the new thread has started.
        Thread thread = e.thread;
        assertNotNull(thread);
        assertTrue(thread.isAlive());

        thread.join();
        assertTrue(task.ran.get());

        // Ensure another new thread starts again.
        task.ran.set(false);
        e.execute(task);
        assertNotSame(e.thread, thread);
        thread = e.thread;

        thread.join();

        assertTrue(task.ran.get());
    }