io.netty.util.concurrent

类 PromiseCombiner

java.lang.Object

io.netty.util.concurrent.PromiseCombiner

public final class PromiseCombiner
extends java.lang.Object

A promise combiner monitors the outcome of a number of discrete futures, then notifies a final, aggregate promise when all of the combined futures are finished. The aggregate promise will succeed if and only if all of the combined futures succeed. If any of the combined futures fail, the aggregate promise will fail. The cause failure for the aggregate promise will be the failure for one of the failed combined futures; if more than one of the combined futures fails, exactly which cause of failure will be assigned to the aggregate promise is undefined.

Callers may populate a promise combiner with any number of futures to be combined via the add(Future) and addAll(Future[]) methods. When all futures to be combined have been added, callers must provide an aggregate promise to be notified when all combined promises have finished via the finish(Promise) method.

This implementation is NOT thread-safe and all methods must be called from the EventExecutor thread.

构造器概要

构造器

构造器和说明
PromiseCombiner() 已过时。
PromiseCombiner(EventExecutor executor) The EventExecutor to use for notifications.

方法概要

限定符和类型	方法和说明
void	add(Future future) Adds a new future to be combined.
void	add(Promise promise) 已过时。 Replaced by add(Future).
void	addAll(Future... futures) Adds new futures to be combined.
void	addAll(Promise... promises) 已过时。 Replaced by addAll(Future[])
void	finish(Promise<java.lang.Void> aggregatePromise) Sets the promise to be notified when all combined futures have finished.

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

PromiseCombiner

@Deprecated
public PromiseCombiner()

已过时。

Deprecated use PromiseCombiner(EventExecutor).

PromiseCombiner

public PromiseCombiner(EventExecutor executor)

The EventExecutor to use for notifications. You must call add(Future), addAll(Future[]) and finish(Promise) from within the EventExecutor thread.

参数:

executor - the EventExecutor to use for notifications.

方法详细资料

add

@Deprecated
public void add(Promise promise)

已过时。 Replaced by add(Future).

Adds a new promise to be combined. New promises may be added until an aggregate promise is added via the finish(Promise) method.

参数:

promise - the promise to add to this promise combiner

add

public void add(Future future)

Adds a new future to be combined. New futures may be added until an aggregate promise is added via the finish(Promise) method.

参数:

future - the future to add to this promise combiner

addAll

@Deprecated
public void addAll(Promise... promises)

已过时。 Replaced by addAll(Future[])

Adds new promises to be combined. New promises may be added until an aggregate promise is added via the finish(Promise) method.

参数:

promises - the promises to add to this promise combiner

addAll

public void addAll(Future... futures)

Adds new futures to be combined. New futures may be added until an aggregate promise is added via the finish(Promise) method.

参数:

futures - the futures to add to this promise combiner

finish

public void finish(Promise<java.lang.Void> aggregatePromise)

Sets the promise to be notified when all combined futures have finished. If all combined futures succeed, then the aggregate promise will succeed. If one or more combined futures fails, then the aggregate promise will fail with the cause of one of the failed futures. If more than one combined future fails, then exactly which failure will be assigned to the aggregate promise is undefined.

After this method is called, no more futures may be added via the add(Future) or addAll(Future[]) methods.

参数:

aggregatePromise - the promise to notify when all combined futures have finished