@UnstableApi public final class DelegatingChannelPromiseNotifier extends java.lang.Object implements ChannelPromise, ChannelFutureListener
CLOSE, CLOSE_ON_FAILURE, FIRE_EXCEPTION_ON_FAILURE
Constructor and Description |
---|
DelegatingChannelPromiseNotifier(ChannelPromise delegate) |
DelegatingChannelPromiseNotifier(ChannelPromise delegate, boolean logNotifyFailure) |
Modifier and Type | Method and Description |
---|---|
ChannelPromise |
addListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener)
将指定的侦听器添加到此将来。
|
ChannelPromise |
addListeners(GenericFutureListener<? extends Future<? super java.lang.Void>>... listeners)
将指定的侦听器添加到此将来。
|
ChannelPromise |
await()
等待这个未来的完成。
|
boolean |
await(long timeoutMillis)
等待这个未来在规定的时限内完成。
|
boolean |
await(long timeout, java.util.concurrent.TimeUnit unit)
等待这个未来在规定的时限内完成。
|
ChannelPromise |
awaitUninterruptibly()
等待这个未来不中断地完成。
|
boolean |
awaitUninterruptibly(long timeoutMillis)
等待这个未来在规定的时间内完成而不会中断。
|
boolean |
awaitUninterruptibly(long timeout, java.util.concurrent.TimeUnit unit)
等待这个未来在规定的时间内完成而不会中断。
|
boolean |
cancel(boolean mayInterruptIfRunning)
如果取消成功,将会以
CancellationException 失败。
|
java.lang.Throwable |
cause()
如果I / O操作失败,则返回失败的I / O操作的原因。
|
Channel |
channel()
返回与此未来相关的I / O操作发生的通道。
|
java.lang.Void |
get() |
java.lang.Void |
get(long timeout, java.util.concurrent.TimeUnit unit) |
java.lang.Void |
getNow()
无阻塞地返回结果。
|
boolean |
isCancellable()
返回
true 当且仅当该操作可通过取消
Future.cancel(boolean) 。
|
boolean |
isCancelled() |
boolean |
isDone() |
boolean |
isSuccess()
当且仅当I / O操作成功完成时返回
true 。
|
boolean |
isVoid()
返回 true 如果这ChannelFuture 是一个无效的未来,所以不允许调用任何下列方法: ChannelFuture.addListener(GenericFutureListener) ChannelFuture.addListeners(GenericFutureListener[]) ChannelFuture.await() Future.await(long, TimeUnit) ()} Future.await(long) ()} ChannelFuture.awaitUninterruptibly() ChannelFuture.sync() ChannelFuture.syncUninterruptibly()
|
void |
operationComplete(ChannelFuture future)
当与 Future 相关的操作完成时调用。
|
ChannelPromise |
removeListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener)
从此将来删除指定侦听器的第一个匹配项。
|
ChannelPromise |
removeListeners(GenericFutureListener<? extends Future<? super java.lang.Void>>... listeners)
为将来的每个听众删除第一个匹配项。
|
ChannelPromise |
setFailure(java.lang.Throwable cause)
将这个未来标志为失败并通知所有听众。
|
ChannelPromise |
setSuccess() |
ChannelPromise |
setSuccess(java.lang.Void result)
将这个未来标志为成功并通知所有听众。
|
boolean |
setUncancellable()
使这个未来无法取消。
|
ChannelPromise |
sync()
等待这个未来,直到完成,并且在这个未来失败的时候重新引发失败的原因。
|
ChannelPromise |
syncUninterruptibly()
等待这个未来,直到完成,并且在这个未来失败的时候重新引发失败的原因。
|
boolean |
tryFailure(java.lang.Throwable cause)
将这个未来标志为失败并通知所有听众。
|
boolean |
trySuccess() |
boolean |
trySuccess(java.lang.Void result)
将这个未来标志为成功并通知所有听众。
|
ChannelPromise |
unvoid()
如果 ChannelFuture.isVoid() 返回true 则返回新的ChannelPromise 。
|
public DelegatingChannelPromiseNotifier(ChannelPromise delegate)
public DelegatingChannelPromiseNotifier(ChannelPromise delegate, boolean logNotifyFailure)
public void operationComplete(ChannelFuture future) throws java.lang.Exception
GenericFutureListener
Future
相关的操作已完成时调用。
operationComplete
接口
GenericFutureListener<ChannelFuture>
future
- 调用此回调的源Future
java.lang.Exception
public Channel channel()
ChannelFuture
channel
在界面
ChannelFuture
channel
,界面
ChannelPromise
public ChannelPromise setSuccess(java.lang.Void result)
Promise
复制的描述
IllegalStateException
。
setSuccess
在界面
ChannelPromise
setSuccess
接口
Promise<java.lang.Void>
public ChannelPromise setSuccess()
setSuccess
接口
ChannelPromise
public boolean trySuccess()
trySuccess
在界面
ChannelPromise
public boolean trySuccess(java.lang.Void result)
Promise
trySuccess
接口
Promise<java.lang.Void>
true
当且仅当成功标记这个未来是成功的。
否则false
因为这个未来已被标记为成功或失败。
public ChannelPromise setFailure(java.lang.Throwable cause)
Promise
IllegalStateException
。
setFailure
,界面
ChannelPromise
setFailure
接口
Promise<java.lang.Void>
public ChannelPromise addListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener)
Future
addListener
,界面
ChannelFuture
addListener
接口
ChannelPromise
addListener
接口
Promise<java.lang.Void>
public ChannelPromise addListeners(GenericFutureListener<? extends Future<? super java.lang.Void>>... listeners)
Future
复制的描述
addListeners
接口
ChannelFuture
addListeners
接口
ChannelPromise
addListeners
在界面
Promise<java.lang.Void>
public ChannelPromise removeListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener)
Future
removeListener
在界面
ChannelFuture
removeListener
在界面
ChannelPromise
removeListener
,界面
Promise<java.lang.Void>
public ChannelPromise removeListeners(GenericFutureListener<? extends Future<? super java.lang.Void>>... listeners)
Future
removeListeners
在界面
ChannelFuture
removeListeners
接口
ChannelPromise
removeListeners
接口
Promise<java.lang.Void>
public boolean tryFailure(java.lang.Throwable cause)
Promise
复制的描述
tryFailure
在界面
Promise<java.lang.Void>
true
当且仅当成功将这个未来标记为失败。
否则false
因为这个未来已经被标记为成功或失败。
public boolean setUncancellable()
Promise
setUncancellable
接口
Promise<java.lang.Void>
true
当且仅当成功地将这个未来标记为不可取消或已经完成而未被取消。
false
如果这个未来已经被取消了。
public ChannelPromise await() throws java.lang.InterruptedException
Future
await
接口
ChannelFuture
await
接口
ChannelPromise
await
在界面
Promise<java.lang.Void>
java.lang.InterruptedException
- 如果当前线程中断
public ChannelPromise awaitUninterruptibly()
Future
InterruptedException
并以静默方式丢弃它。
awaitUninterruptibly
在界面
ChannelFuture
awaitUninterruptibly
接口
ChannelPromise
awaitUninterruptibly
,界面
Promise<java.lang.Void>
public boolean isVoid()
ChannelFuture
ChannelFuture
是一个无效的未来,并且不允许调用以下任何方法,则返回true
:
isVoid
接口
ChannelFuture
public ChannelPromise unvoid()
ChannelPromise
ChannelFuture.isVoid()
返回true
则返回新的ChannelPromise
。
unvoid
接口
ChannelPromise
public boolean await(long timeout, java.util.concurrent.TimeUnit unit) throws java.lang.InterruptedException
Future
复制的描述
true
当且仅当未来在规定的时限内完成
java.lang.InterruptedException
- 如果当前线程中断
public boolean await(long timeoutMillis) throws java.lang.InterruptedException
Future
true
当且仅当未来在规定的时限内完成
java.lang.InterruptedException
- 如果当前线程中断
public boolean awaitUninterruptibly(long timeout, java.util.concurrent.TimeUnit unit)
Future
InterruptedException
并以静默方式丢弃它。
true
当且仅当未来在规定的时限内完成
public boolean awaitUninterruptibly(long timeoutMillis)
Future
InterruptedException
并以静默方式丢弃它。
true
当且仅当未来在规定的时限内完成
public java.lang.Void getNow()
Future
null
。
由于可能使用null
值标记未来成功,因此您还需要检查未来是否真的用Future.isDone()
完成,而不是在返回的null
值上进行中继。
public boolean cancel(boolean mayInterruptIfRunning)
Future
CancellationException
未来失败。
cancel
在界面
java.util.concurrent.Future<java.lang.Void>
public boolean isCancelled()
isCancelled
接口
java.util.concurrent.Future<java.lang.Void>
public boolean isDone()
isDone
接口
java.util.concurrent.Future<java.lang.Void>
public java.lang.Void get() throws java.lang.InterruptedException, java.util.concurrent.ExecutionException
get
接口
java.util.concurrent.Future<java.lang.Void>
java.lang.InterruptedException
java.util.concurrent.ExecutionException
public java.lang.Void get(long timeout, java.util.concurrent.TimeUnit unit) throws java.lang.InterruptedException, java.util.concurrent.ExecutionException, java.util.concurrent.TimeoutException
get
接口
java.util.concurrent.Future<java.lang.Void>
java.lang.InterruptedException
java.util.concurrent.ExecutionException
java.util.concurrent.TimeoutException
public ChannelPromise sync() throws java.lang.InterruptedException
Future
sync
在界面
ChannelFuture
sync
在界面
ChannelPromise
sync
接口
Promise<java.lang.Void>
java.lang.InterruptedException
public ChannelPromise syncUninterruptibly()
Future
syncUninterruptibly
接口
ChannelFuture
syncUninterruptibly
接口
ChannelPromise
syncUninterruptibly
,界面
Promise<java.lang.Void>
public boolean isSuccess()
Future
true
。
public boolean isCancellable()
Future
true
当且仅当该操作可通过取消
Future.cancel(boolean)
。
public java.lang.Throwable cause()
Future
复制的描述
null
如果成功或未来尚未完成。
Copyright © 2008–2018 The Netty Project. All rights reserved.