public class RpcFuture<T> extends Object implements AsyncAwareFuture<T>
| 构造器和说明 |
|---|
RpcFuture() |
RpcFuture(long logId) |
RpcFuture(io.netty.util.Timeout timeout,
RpcMethodInfo rpcMethodInfo,
RpcCallback<T> callback,
ChannelInfo channelInfo,
RpcClient rpcClient) |
| 限定符和类型 | 方法和说明 |
|---|---|
boolean |
cancel(boolean mayInterruptIfRunning) |
T |
get() |
T |
get(long timeout,
TimeUnit unit) |
void |
handleConnection(Response response) |
void |
handleResponse(Response response) |
void |
init(io.netty.util.Timeout timeout,
RpcMethodInfo rpcMethodInfo,
RpcCallback<T> callback,
ChannelInfo channelInfo,
RpcClient rpcClient) |
boolean |
isAsync() |
boolean |
isCancelled() |
boolean |
isDone() |
String |
toString() |
public RpcFuture()
public RpcFuture(long logId)
public RpcFuture(io.netty.util.Timeout timeout,
RpcMethodInfo rpcMethodInfo,
RpcCallback<T> callback,
ChannelInfo channelInfo,
RpcClient rpcClient)
public void init(io.netty.util.Timeout timeout,
RpcMethodInfo rpcMethodInfo,
RpcCallback<T> callback,
ChannelInfo channelInfo,
RpcClient rpcClient)
public void handleConnection(Response response)
public void handleResponse(Response response)
public boolean isAsync()
isAsync 在接口中 AsyncAwareFuture<T>public boolean isCancelled()
isCancelled 在接口中 Future<T>public T get() throws InterruptedException
get 在接口中 Future<T>InterruptedExceptionCopyright © 2019 Baidu, Inc.. All rights reserved.