Class AbstractEventExecutorGroup

    • Constructor Detail

      • AbstractEventExecutorGroup

        public AbstractEventExecutorGroup()
    • Method Detail

      • submit

        public Future<?> submit​(java.lang.Runnable task)
        Specified by:
        submit in interface EventExecutorGroup
        Specified by:
        submit in interface java.util.concurrent.ExecutorService
      • submit

        public <T> Future<T> submit​(java.lang.Runnable task,
                                    T result)
        Specified by:
        submit in interface EventExecutorGroup
        Specified by:
        submit in interface java.util.concurrent.ExecutorService
      • submit

        public <T> Future<T> submit​(java.util.concurrent.Callable<T> task)
        Specified by:
        submit in interface EventExecutorGroup
        Specified by:
        submit in interface java.util.concurrent.ExecutorService
      • schedule

        public ScheduledFuture<?> schedule​(java.lang.Runnable command,
                                           long delay,
                                           java.util.concurrent.TimeUnit unit)
        Specified by:
        schedule in interface EventExecutorGroup
        Specified by:
        schedule in interface java.util.concurrent.ScheduledExecutorService
      • schedule

        public <V> ScheduledFuture<V> schedule​(java.util.concurrent.Callable<V> callable,
                                               long delay,
                                               java.util.concurrent.TimeUnit unit)
        Specified by:
        schedule in interface EventExecutorGroup
        Specified by:
        schedule in interface java.util.concurrent.ScheduledExecutorService
      • scheduleAtFixedRate

        public ScheduledFuture<?> scheduleAtFixedRate​(java.lang.Runnable command,
                                                      long initialDelay,
                                                      long period,
                                                      java.util.concurrent.TimeUnit unit)
        Specified by:
        scheduleAtFixedRate in interface EventExecutorGroup
        Specified by:
        scheduleAtFixedRate in interface java.util.concurrent.ScheduledExecutorService
      • scheduleWithFixedDelay

        public ScheduledFuture<?> scheduleWithFixedDelay​(java.lang.Runnable command,
                                                         long initialDelay,
                                                         long delay,
                                                         java.util.concurrent.TimeUnit unit)
        Specified by:
        scheduleWithFixedDelay in interface EventExecutorGroup
        Specified by:
        scheduleWithFixedDelay in interface java.util.concurrent.ScheduledExecutorService
      • invokeAll

        public <T> java.util.List<java.util.concurrent.Future<T>> invokeAll​(java.util.Collection<? extends java.util.concurrent.Callable<T>> tasks)
                                                                     throws java.lang.InterruptedException
        Specified by:
        invokeAll in interface java.util.concurrent.ExecutorService
        Throws:
        java.lang.InterruptedException
      • invokeAll

        public <T> java.util.List<java.util.concurrent.Future<T>> invokeAll​(java.util.Collection<? extends java.util.concurrent.Callable<T>> tasks,
                                                                            long timeout,
                                                                            java.util.concurrent.TimeUnit unit)
                                                                     throws java.lang.InterruptedException
        Specified by:
        invokeAll in interface java.util.concurrent.ExecutorService
        Throws:
        java.lang.InterruptedException
      • invokeAny

        public <T> T invokeAny​(java.util.Collection<? extends java.util.concurrent.Callable<T>> tasks)
                        throws java.lang.InterruptedException,
                               java.util.concurrent.ExecutionException
        Specified by:
        invokeAny in interface java.util.concurrent.ExecutorService
        Throws:
        java.lang.InterruptedException
        java.util.concurrent.ExecutionException
      • invokeAny

        public <T> T invokeAny​(java.util.Collection<? extends java.util.concurrent.Callable<T>> tasks,
                               long timeout,
                               java.util.concurrent.TimeUnit unit)
                        throws java.lang.InterruptedException,
                               java.util.concurrent.ExecutionException,
                               java.util.concurrent.TimeoutException
        Specified by:
        invokeAny in interface java.util.concurrent.ExecutorService
        Throws:
        java.lang.InterruptedException
        java.util.concurrent.ExecutionException
        java.util.concurrent.TimeoutException
      • execute

        public void execute​(java.lang.Runnable command)
        Specified by:
        execute in interface java.util.concurrent.Executor