shutdown() — netty Function Reference

Architecture documentation for the shutdown() function in BurstCostExecutorsBenchmark.java from the netty codebase.

Function java Buffer Search called by 1

Entity Profile

Buffer→ Search→ shutdown() — netty Function Reference

Dependency Diagram

graph TD
  acd9ae03_5540_8a87_ff13_29bd36434ae9["shutdown()"]
  e1d20ecf_b9ac_4de1_4575_dd9260dd6753["SpinExecutorService"]
  acd9ae03_5540_8a87_ff13_29bd36434ae9 -->|defined in| e1d20ecf_b9ac_4de1_4575_dd9260dd6753
  6e74c2dd_a082_e375_1ee7_a99b3cc88b4f["tearDown()"]
  6e74c2dd_a082_e375_1ee7_a99b3cc88b4f -->|calls| acd9ae03_5540_8a87_ff13_29bd36434ae9
  style acd9ae03_5540_8a87_ff13_29bd36434ae9 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

microbench/src/main/java/io/netty/microbench/concurrent/BurstCostExecutorsBenchmark.java lines 87–99

        @Override
        public void shutdown() {
            if (poisoned.compareAndSet(false, true)) {
                while (!tasks.offer(POISON_PILL)) {
                    // Just try again
                }
                try {
                    executorThread.join();
                } catch (InterruptedException e) {
                    //We're quite trusty :)
                }
            }
        }