Class CompositeIoFuture<E extends IoFuture>

java.lang.Object

org.apache.mina.core.future.DefaultIoFuture

org.apache.mina.core.future.CompositeIoFuture<E>

Type Parameters:

E - the type of the child futures.

All Implemented Interfaces:

IoFuture

public class CompositeIoFuture<E extends IoFuture>
extends DefaultIoFuture

An IoFuture of IoFutures. It is useful when you want to get notified when all IoFutures are complete. It is not recommended to use CompositeIoFuture if you just want to wait for all futures. In that case, please use IoUtil.await(Iterable) instead for better performance.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private class	CompositeIoFuture.NotifyingListener

Field Summary

Fields

Modifier and Type	Field	Description
private boolean	constructionFinished	A flag set to TRUE when all the future have been added to the list
private final CompositeIoFuture<E>.NotifyingListener	listener	A listener
private final AtomicInteger	unnotified	A thread safe counter that is used to keep a track of the notified futures

Constructor Summary

Constructors

Constructor	Description
CompositeIoFuture(Iterable<E> children)	Creates a new CompositeIoFuture instance

Method Summary

Methods inherited from class DefaultIoFuture

addListener, await, await, await, awaitUninterruptibly, awaitUninterruptibly, awaitUninterruptibly, getSession, getValue, isDone, join, join, removeListener, setValue

Methods inherited from class Object

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

Field Details

listener

private final CompositeIoFuture<E extends IoFuture>.NotifyingListener listener

A listener

unnotified

private final AtomicInteger unnotified

A thread safe counter that is used to keep a track of the notified futures

constructionFinished

private volatile boolean constructionFinished

A flag set to TRUE when all the future have been added to the list

Constructor Details

CompositeIoFuture

public CompositeIoFuture(Iterable<E> children)

Creates a new CompositeIoFuture instance

Parameters:

children - The list of internal futures