public class DefaultProgressivePromise<V> extends DefaultPromise<V> implements ProgressivePromise<V>
Modifier | Constructor and Description |
---|---|
protected |
DefaultProgressivePromise() |
|
DefaultProgressivePromise(EventExecutor executor)
创建一个新的实例。
|
Modifier and Type | Method and Description |
---|---|
ProgressivePromise<V> |
addListener(GenericFutureListener<? extends Future<? super V>> listener)
将指定的侦听器添加到此将来。
|
ProgressivePromise<V> |
addListeners(GenericFutureListener<? extends Future<? super V>>... listeners)
将指定的侦听器添加到此将来。
|
ProgressivePromise<V> |
await()
等待这个未来的完成。
|
ProgressivePromise<V> |
awaitUninterruptibly()
等待这个未来不中断地完成。
|
ProgressivePromise<V> |
removeListener(GenericFutureListener<? extends Future<? super V>> listener)
从此将来删除指定侦听器的第一个匹配项。
|
ProgressivePromise<V> |
removeListeners(GenericFutureListener<? extends Future<? super V>>... listeners)
为将来的每个听众删除第一个匹配项。
|
ProgressivePromise<V> |
setFailure(java.lang.Throwable cause)
将这个未来标志为失败并通知所有听众。
|
ProgressivePromise<V> |
setProgress(long progress, long total)
设置操作的当前进度并通知执行 GenericProgressiveFutureListener 的侦听器 。
|
ProgressivePromise<V> |
setSuccess(V result)
将这个未来标志为成功并通知所有听众。
|
ProgressivePromise<V> |
sync()
等待这个未来,直到完成,并且在这个未来失败的时候重新引发失败的原因。
|
ProgressivePromise<V> |
syncUninterruptibly()
等待这个未来,直到完成,并且在这个未来失败的时候重新引发失败的原因。
|
boolean |
tryProgress(long progress, long total)
尝试设置操作的当前进度并通知实施 GenericProgressiveFutureListener 的听众。
|
await, await, awaitUninterruptibly, awaitUninterruptibly, cancel, cause, checkDeadLock, executor, getNow, isCancellable, isCancelled, isDone, isSuccess, notifyListener, setUncancellable, toString, toStringBuilder, tryFailure, trySuccess
get, get
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
setUncancellable, tryFailure, trySuccess
await, await, awaitUninterruptibly, awaitUninterruptibly, cancel, cause, getNow, isCancellable, isSuccess
public DefaultProgressivePromise(EventExecutor executor)
EventExecutor.newProgressivePromise()
来创建一个新的进步承诺
executor
- EventExecutor
用于通知承诺,当它进展或完成时
protected DefaultProgressivePromise()
public ProgressivePromise<V> setProgress(long progress, long total)
ProgressivePromise
复制的描述
GenericProgressiveFutureListener
的侦听器 。
setProgress
,界面
ProgressivePromise<V>
public boolean tryProgress(long progress, long total)
ProgressivePromise
GenericProgressiveFutureListener
的听众。
如果操作已完成或进度超出范围,则此方法false
返回false
。
tryProgress
接口
ProgressivePromise<V>
public ProgressivePromise<V> addListener(GenericFutureListener<? extends Future<? super V>> listener)
Future
addListener
,界面
ProgressiveFuture<V>
addListener
接口
ProgressivePromise<V>
addListener
在界面
Promise<V>
addListener
在班级
DefaultPromise<V>
public ProgressivePromise<V> addListeners(GenericFutureListener<? extends Future<? super V>>... listeners)
Future
addListeners
,界面
ProgressiveFuture<V>
addListeners
,界面
ProgressivePromise<V>
addListeners
,界面
Promise<V>
addListeners
在课堂
DefaultPromise<V>
public ProgressivePromise<V> removeListener(GenericFutureListener<? extends Future<? super V>> listener)
Future
复制的描述
removeListener
接口
ProgressiveFuture<V>
removeListener
接口
ProgressivePromise<V>
removeListener
接口
Promise<V>
removeListener
在课堂
DefaultPromise<V>
public ProgressivePromise<V> removeListeners(GenericFutureListener<? extends Future<? super V>>... listeners)
Future
复制的描述
removeListeners
接口
ProgressiveFuture<V>
removeListeners
接口
ProgressivePromise<V>
removeListeners
在界面
Promise<V>
removeListeners
在课堂
DefaultPromise<V>
public ProgressivePromise<V> sync() throws java.lang.InterruptedException
Future
sync
接口
ProgressiveFuture<V>
sync
接口
ProgressivePromise<V>
sync
接口
Promise<V>
sync
在课堂
DefaultPromise<V>
java.lang.InterruptedException
public ProgressivePromise<V> syncUninterruptibly()
Future
syncUninterruptibly
接口
ProgressiveFuture<V>
syncUninterruptibly
,界面
ProgressivePromise<V>
syncUninterruptibly
,界面
Promise<V>
syncUninterruptibly
在课堂
DefaultPromise<V>
public ProgressivePromise<V> await() throws java.lang.InterruptedException
Future
复制的描述
await
,界面
ProgressiveFuture<V>
await
接口
ProgressivePromise<V>
await
接口
Promise<V>
await
在课堂
DefaultPromise<V>
java.lang.InterruptedException
- 如果当前线程中断
public ProgressivePromise<V> awaitUninterruptibly()
Future
InterruptedException
并以静默方式丢弃它。
awaitUninterruptibly
接口
ProgressiveFuture<V>
awaitUninterruptibly
接口
ProgressivePromise<V>
awaitUninterruptibly
接口
Promise<V>
awaitUninterruptibly
在课堂
DefaultPromise<V>
public ProgressivePromise<V> setSuccess(V result)
Promise
IllegalStateException
。
setSuccess
在界面
ProgressivePromise<V>
setSuccess
接口
Promise<V>
setSuccess
在课堂
DefaultPromise<V>
public ProgressivePromise<V> setFailure(java.lang.Throwable cause)
Promise
IllegalStateException
。
setFailure
接口
ProgressivePromise<V>
setFailure
,界面
Promise<V>
setFailure
在课堂
DefaultPromise<V>
Copyright © 2008–2018 The Netty Project. All rights reserved.