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, getprotected 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.