public abstract class CompleteFuture<V> extends AbstractFuture<V>
Modifier | Constructor and Description |
---|---|
protected |
CompleteFuture(EventExecutor executor)
创建一个新的实例。
|
Modifier and Type | Method and Description |
---|---|
Future<V> |
addListener(GenericFutureListener<? extends Future<? super V>> listener)
将指定的侦听器添加到此将来。
|
Future<V> |
addListeners(GenericFutureListener<? extends Future<? super V>>... listeners)
将指定的侦听器添加到此将来。
|
Future<V> |
await()
等待这个未来的完成。
|
boolean |
await(long timeoutMillis)
等待这个未来在规定的时限内完成。
|
boolean |
await(long timeout, java.util.concurrent.TimeUnit unit)
等待这个未来在规定的时限内完成。
|
Future<V> |
awaitUninterruptibly()
等待这个未来不中断地完成。
|
boolean |
awaitUninterruptibly(long timeoutMillis)
等待这个未来在规定的时间内完成而不会中断。
|
boolean |
awaitUninterruptibly(long timeout, java.util.concurrent.TimeUnit unit)
等待这个未来在规定的时间内完成而不会中断。
|
boolean |
cancel(boolean mayInterruptIfRunning)
如果取消成功,它将以
CancellationException 未来失败。
|
protected EventExecutor |
executor()
返回 CompleteFuture 使用的EventExecutor 。
|
boolean |
isCancellable()
返回
true 当且仅当该操作可通过取消
Future.cancel(boolean) 。
|
boolean |
isCancelled() |
boolean |
isDone() |
Future<V> |
removeListener(GenericFutureListener<? extends Future<? super V>> listener)
从此将来删除指定侦听器的第一个匹配项。
|
Future<V> |
removeListeners(GenericFutureListener<? extends Future<? super V>>... listeners)
为将来的每个听众删除第一个匹配项。
|
Future<V> |
sync()
等待这个未来,直到完成,并且在这个未来失败的时候重新引发失败的原因。
|
Future<V> |
syncUninterruptibly()
等待这个未来,直到完成,并且在这个未来失败的时候重新引发失败的原因。
|
get, get
protected CompleteFuture(EventExecutor executor)
executor
- 与这个未来相关的EventExecutor
protected EventExecutor executor()
CompleteFuture
使用的EventExecutor
。
public Future<V> addListener(GenericFutureListener<? extends Future<? super V>> listener)
Future
public Future<V> addListeners(GenericFutureListener<? extends Future<? super V>>... listeners)
Future
public Future<V> removeListener(GenericFutureListener<? extends Future<? super V>> listener)
Future
public Future<V> removeListeners(GenericFutureListener<? extends Future<? super V>>... listeners)
Future
复制的描述
public Future<V> await() throws java.lang.InterruptedException
Future
java.lang.InterruptedException
- 如果当前线程中断
public boolean await(long timeout, java.util.concurrent.TimeUnit unit) throws java.lang.InterruptedException
Future
true
当且仅当未来在规定的时限内完成
java.lang.InterruptedException
- 如果当前线程中断
public Future<V> sync() throws java.lang.InterruptedException
Future
java.lang.InterruptedException
public Future<V> syncUninterruptibly()
Future
public boolean await(long timeoutMillis) throws java.lang.InterruptedException
Future
true
当且仅当未来在规定的时限内完成
java.lang.InterruptedException
- 如果当前线程中断
public Future<V> awaitUninterruptibly()
Future
InterruptedException
并以InterruptedException
提示方式丢弃它。
public boolean awaitUninterruptibly(long timeout, java.util.concurrent.TimeUnit unit)
Future
InterruptedException
并以InterruptedException
提示的方式丢弃它。
true
当且仅当未来在规定的时间限制内完成
public boolean awaitUninterruptibly(long timeoutMillis)
Future
InterruptedException
,并以静默方式丢弃它。
true
当且仅当未来在规定的时限内完成
public boolean isDone()
public boolean isCancellable()
Future
true
当且仅当该操作可通过取消
Future.cancel(boolean)
。
public boolean isCancelled()
public boolean cancel(boolean mayInterruptIfRunning)
CancellationException
失败。
mayInterruptIfRunning
- 此值在此实现中不起作用。
Copyright © 2008–2018 The Netty Project. All rights reserved.