PromiseCombiner
GenericFutureListener
实现,将Future
合并为一个,通过监听单个Future
并在所有Future
完成时产生聚合结果(成功/失败)。
@Deprecated public class PromiseAggregator<V,F extends Future<V>> extends java.lang.Object implements GenericFutureListener<F>
Constructor and Description |
---|
PromiseAggregator(Promise<java.lang.Void> aggregatePromise)
已过时。
|
PromiseAggregator(Promise<java.lang.Void> aggregatePromise, boolean failPending)
已过时。
创建一个新的实例。
|
public PromiseAggregator(Promise<java.lang.Void> aggregatePromise, boolean failPending)
aggregatePromise
- Promise
通知
failPending
-
true
失败未决的承诺,假让它们不受影响
public PromiseAggregator(Promise<java.lang.Void> aggregatePromise)
PromiseAggregator(Promise, boolean)
。
默认failPending
为true。
@SafeVarargs public final PromiseAggregator<V,F> add(Promise<V>... promises)
Promise
添加到聚合器。
public void operationComplete(F future) throws java.lang.Exception
GenericFutureListener
Future
相关的操作已完成时调用。
operationComplete
,界面
GenericFutureListener<F extends Future<V>>
future
- 调用此回调的源Future
java.lang.Exception
Copyright © 2008–2018 The Netty Project. All rights reserved.