testThreadGroup() — netty Function Reference

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

Function java Buffer Telemetry calls 1

Entity Profile

Buffer→ Telemetry→ testThreadGroup() — netty Function Reference

Dependency Diagram

graph TD
  1daf62c2_7d3f_df4c_401c_94f838678ae9["testThreadGroup()"]
  f5a88566_416e_7970_655d_74968e21adb8["GlobalEventExecutorTest"]
  1daf62c2_7d3f_df4c_401c_94f838678ae9 -->|defined in| f5a88566_416e_7970_655d_74968e21adb8
  146f29d4_d7b0_af2d_af77_7a421da95324["run()"]
  1daf62c2_7d3f_df4c_401c_94f838678ae9 -->|calls| 146f29d4_d7b0_af2d_af77_7a421da95324
  style 1daf62c2_7d3f_df4c_401c_94f838678ae9 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

common/src/test/java/io/netty/util/concurrent/GlobalEventExecutorTest.java lines 91–111

    @Test
    @Timeout(value = 2000, unit = TimeUnit.MILLISECONDS)
    public void testThreadGroup() throws InterruptedException {
        final ThreadGroup group = new ThreadGroup("group");
        final AtomicReference<ThreadGroup> capturedGroup = new AtomicReference<ThreadGroup>();
        final Thread thread = new Thread(group, new Runnable() {
            @Override
            public void run() {
                final Thread t = e.threadFactory.newThread(new Runnable() {
                    @Override
                    public void run() {
                    }
                });
                capturedGroup.set(t.getThreadGroup());
            }
        });
        thread.start();
        thread.join();

        assertEquals(group, capturedGroup.get());
    }