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, trySuccessget, getclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitsetUncancellable, tryFailure, trySuccessawait, await, awaitUninterruptibly, awaitUninterruptibly, cancel, cause, getNow, isCancellable, isSuccesspublic 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.