Class DefaultChannelGroupFuture

    • Constructor Detail

      • DefaultChannelGroupFuture

        public DefaultChannelGroupFuture​(ChannelGroup group,
                                         java.util.Collection<ChannelFuture> futures)
        Creates a new instance.
      • DefaultChannelGroupFuture

        DefaultChannelGroupFuture​(ChannelGroup group,
                                  java.util.Map<java.lang.Integer,​ChannelFuture> futures)
    • Method Detail

      • isDone

        public boolean isDone()
        Description copied from interface: ChannelGroupFuture
        Returns true if and only if this future is complete, regardless of whether the operation was successful, failed, or canceled.
        Specified by:
        isDone in interface ChannelGroupFuture
      • isCompleteSuccess

        public boolean isCompleteSuccess()
        Description copied from interface: ChannelGroupFuture
        Returns true if and only if all I/O operations associated with this future were successful without any failure.
        Specified by:
        isCompleteSuccess in interface ChannelGroupFuture
      • isPartialSuccess

        public boolean isPartialSuccess()
        Description copied from interface: ChannelGroupFuture
        Returns true if and only if the I/O operations associated with this future were partially successful with some failure.
        Specified by:
        isPartialSuccess in interface ChannelGroupFuture
      • isPartialFailure

        public boolean isPartialFailure()
        Description copied from interface: ChannelGroupFuture
        Returns true if and only if the I/O operations associated with this future have failed partially with some success.
        Specified by:
        isPartialFailure in interface ChannelGroupFuture
      • isCompleteFailure

        public boolean isCompleteFailure()
        Description copied from interface: ChannelGroupFuture
        Returns true if and only if all I/O operations associated with this future have failed without any success.
        Specified by:
        isCompleteFailure in interface ChannelGroupFuture
      • addListener

        public void addListener​(ChannelGroupFutureListener listener)
        Description copied from interface: ChannelGroupFuture
        Adds the specified listener to this future. The specified listener is notified when this future is done. If this future is already completed, the specified listener is notified immediately.
        Specified by:
        addListener in interface ChannelGroupFuture
      • removeListener

        public void removeListener​(ChannelGroupFutureListener listener)
        Description copied from interface: ChannelGroupFuture
        Removes the specified listener from this future. The specified listener is no longer notified when this future is done. If this future is already completed, this method has no effect and returns silently.
        Specified by:
        removeListener in interface ChannelGroupFuture
      • await

        public ChannelGroupFuture await()
                                 throws java.lang.InterruptedException
        Description copied from interface: ChannelGroupFuture
        Waits for this future to be completed.
        Specified by:
        await in interface ChannelGroupFuture
        Throws:
        java.lang.InterruptedException - if the current thread was interrupted
      • await

        public boolean await​(long timeout,
                             java.util.concurrent.TimeUnit unit)
                      throws java.lang.InterruptedException
        Description copied from interface: ChannelGroupFuture
        Waits for this future to be completed within the specified time limit.
        Specified by:
        await in interface ChannelGroupFuture
        Returns:
        true if and only if the future was completed within the specified time limit
        Throws:
        java.lang.InterruptedException - if the current thread was interrupted
      • await

        public boolean await​(long timeoutMillis)
                      throws java.lang.InterruptedException
        Description copied from interface: ChannelGroupFuture
        Waits for this future to be completed within the specified time limit.
        Specified by:
        await in interface ChannelGroupFuture
        Returns:
        true if and only if the future was completed within the specified time limit
        Throws:
        java.lang.InterruptedException - if the current thread was interrupted
      • awaitUninterruptibly

        public boolean awaitUninterruptibly​(long timeout,
                                            java.util.concurrent.TimeUnit unit)
        Description copied from interface: ChannelGroupFuture
        Waits for this future to be completed within the specified time limit without interruption. This method catches an InterruptedException and discards it silently.
        Specified by:
        awaitUninterruptibly in interface ChannelGroupFuture
        Returns:
        true if and only if the future was completed within the specified time limit
      • awaitUninterruptibly

        public boolean awaitUninterruptibly​(long timeoutMillis)
        Description copied from interface: ChannelGroupFuture
        Waits for this future to be completed within the specified time limit without interruption. This method catches an InterruptedException and discards it silently.
        Specified by:
        awaitUninterruptibly in interface ChannelGroupFuture
        Returns:
        true if and only if the future was completed within the specified time limit
      • await0

        private boolean await0​(long timeoutNanos,
                               boolean interruptable)
                        throws java.lang.InterruptedException
        Throws:
        java.lang.InterruptedException
      • checkDeadLock

        private static void checkDeadLock()
      • setDone

        boolean setDone()
      • notifyListeners

        private void notifyListeners()