shutdownGracefully() — netty Function Reference

Architecture documentation for the shutdownGracefully() function in ThreadPerChannelEventLoopGroup.java from the netty codebase.

Function java Buffer Telemetry calls 2

Entity Profile

Buffer→ Telemetry→ shutdownGracefully() — netty Function Reference

Dependency Diagram

graph TD
  1901a00c_536d_79e2_b2fe_7df578f6aa2c["shutdownGracefully()"]
  087189b8_1bd9_3f4f_71bf_da2f9e819990["ThreadPerChannelEventLoopGroup"]
  1901a00c_536d_79e2_b2fe_7df578f6aa2c -->|defined in| 087189b8_1bd9_3f4f_71bf_da2f9e819990
  33d8df27_6974_99b5_3395_981893ea763a["isTerminated()"]
  1901a00c_536d_79e2_b2fe_7df578f6aa2c -->|calls| 33d8df27_6974_99b5_3395_981893ea763a
  830c16db_984c_670d_1b94_c53487f291a7["terminationFuture()"]
  1901a00c_536d_79e2_b2fe_7df578f6aa2c -->|calls| 830c16db_984c_670d_1b94_c53487f291a7
  style 1901a00c_536d_79e2_b2fe_7df578f6aa2c fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport/src/main/java/io/netty/channel/ThreadPerChannelEventLoopGroup.java lines 155–172

    @Override
    public Future<?> shutdownGracefully(long quietPeriod, long timeout, TimeUnit unit) {
        shuttingDown = true;

        for (EventLoop l: activeChildren) {
            l.shutdownGracefully(quietPeriod, timeout, unit);
        }
        for (EventLoop l: idleChildren) {
            l.shutdownGracefully(quietPeriod, timeout, unit);
        }

        // Notify the future if there was no children.
        if (isTerminated()) {
            terminationFuture.trySuccess(null);
        }

        return terminationFuture();
    }