awaitTermination() — netty Function Reference

Architecture documentation for the awaitTermination() function in MultithreadEventExecutorGroup.java from the netty codebase.

Function java CommonUtil Concurrent calls 1 called by 1

Entity Profile

CommonUtil→ Concurrent→ awaitTermination() — netty Function Reference

Dependency Diagram

graph TD
  0f7cfb9f_3ca8_a7c7_fff4_bc7733723802["awaitTermination()"]
  dd791801_e8f4_25f4_af13_edadaaa8ab64["MultithreadEventExecutorGroup"]
  0f7cfb9f_3ca8_a7c7_fff4_bc7733723802 -->|defined in| dd791801_e8f4_25f4_af13_edadaaa8ab64
  041c61bd_938e_a878_9b59_628b5e1eac33["MultithreadEventExecutorGroup()"]
  041c61bd_938e_a878_9b59_628b5e1eac33 -->|calls| 0f7cfb9f_3ca8_a7c7_fff4_bc7733723802
  d987e5c9_8425_0433_561c_d5bad100928d["isTerminated()"]
  0f7cfb9f_3ca8_a7c7_fff4_bc7733723802 -->|calls| d987e5c9_8425_0433_561c_d5bad100928d
  style 0f7cfb9f_3ca8_a7c7_fff4_bc7733723802 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

common/src/main/java/io/netty/util/concurrent/MultithreadEventExecutorGroup.java lines 239–255

    @Override
    public boolean awaitTermination(long timeout, TimeUnit unit)
            throws InterruptedException {
        long deadline = System.nanoTime() + unit.toNanos(timeout);
        loop: for (EventExecutor l: children) {
            for (;;) {
                long timeLeft = deadline - System.nanoTime();
                if (timeLeft <= 0) {
                    break loop;
                }
                if (l.awaitTermination(timeLeft, TimeUnit.NANOSECONDS)) {
                    break;
                }
            }
        }
        return isTerminated();
    }