awaitTermination() — netty Function Reference

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

Function java CommonUtil Concurrent calls 2

Entity Profile

CommonUtil→ Concurrent→ awaitTermination() — netty Function Reference

Dependency Diagram

graph TD
  5dde786a_53fe_373a_1cf0_b392ac10ab7d["awaitTermination()"]
  c9189467_acbc_07ea_3a8c_fecfe22ec122["SingleThreadEventExecutor"]
  5dde786a_53fe_373a_1cf0_b392ac10ab7d -->|defined in| c9189467_acbc_07ea_3a8c_fecfe22ec122
  957fd634_92d8_ad7a_8d3f_c6d9e5d7ee2a["inEventLoop()"]
  5dde786a_53fe_373a_1cf0_b392ac10ab7d -->|calls| 957fd634_92d8_ad7a_8d3f_c6d9e5d7ee2a
  0fc79ca6_ea0e_8bc2_77f3_53d5847771e7["isTerminated()"]
  5dde786a_53fe_373a_1cf0_b392ac10ab7d -->|calls| 0fc79ca6_ea0e_8bc2_77f3_53d5847771e7
  style 5dde786a_53fe_373a_1cf0_b392ac10ab7d fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

common/src/main/java/io/netty/util/concurrent/SingleThreadEventExecutor.java lines 969–979

    @Override
    public boolean awaitTermination(long timeout, TimeUnit unit) throws InterruptedException {
        ObjectUtil.checkNotNull(unit, "unit");
        if (inEventLoop()) {
            throw new IllegalStateException("cannot await termination of the current thread");
        }

        threadLock.await(timeout, unit);

        return isTerminated();
    }