类ManagedChannel

类ManagedChannel 在 Channel 的基础上提供生命周期管理的功能。

实际实现式就是添加了 shutdown()/shutdownNow() 方法用于关闭 Channel,isShutdown()/isTerminated() 方法用于检测 Channel 状态, 以及 awaitTermination() 方法用于等待关闭操作完成。

类定义

package io.grpc;

public abstract class ManagedChannel extends Channel {}

依然是 abstract class,还继续在 package io.grpc中。

类方法

shutdown()方法

public abstract ManagedChannel shutdown();

发起一个有组织的关闭,期间已经存在的调用将继续,而新的调用将被立即取消。

shutdownNow()方法

public abstract ManagedChannel shutdownNow();

发起一个强制的关闭,期间已经存在的调用和新的调用都将被取消。虽然是强制,关闭过程依然不是即可生效;如果在这个方法返回后立即调用 isTerminated() 方法,将可能返回 false 。

isShutdown()方法

public abstract boolean isShutdown();

返回channel是否是关闭。关闭的channel立即取消任何新的调用,但是将继续有一些正在处理的调用。

isTerminated()方法

public abstract boolean isTerminated();

返回channel是否是结束。结束的 channel 没有运行中的调用,并且相关的资源已经释放(像TCP连接)。

awaitTermination()方法

public abstract boolean awaitTermination(long timeout, TimeUnit unit) throws InterruptedException;

等待 channel 变成结束,如果超时时间达到则放弃。

返回值表明 channel 是否结束,和 isTerminated() 方法一致。