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.