Class CompositeIoFuture<E extends IoFuture>

    • Field Detail

      • unnotified

        private final java.util.concurrent.atomic.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 Detail

      • CompositeIoFuture

        public CompositeIoFuture​(java.lang.Iterable<E> children)
        Creates a new CompositeIoFuture instance
        Parameters:
        children - The list of internal futures