com.alipay.sofa.jraft.util.concurrent

Class DefaultFixedThreadsExecutorGroup

java.lang.Object

com.alipay.sofa.jraft.util.concurrent.DefaultFixedThreadsExecutorGroup

All Implemented Interfaces:

FixedThreadsExecutorGroup, Iterable<SingleThreadExecutor>

public final class DefaultFixedThreadsExecutorGroup
extends Object
implements FixedThreadsExecutorGroup

Author:

jiachun.fjc

Constructor Summary

Constructors

Constructor and Description
DefaultFixedThreadsExecutorGroup(ExecutorService[] executors)
DefaultFixedThreadsExecutorGroup(ExecutorService[] executors, ExecutorChooserFactory.ExecutorChooser chooser)
DefaultFixedThreadsExecutorGroup(SingleThreadExecutor[] children)
DefaultFixedThreadsExecutorGroup(SingleThreadExecutor[] children, ExecutorChooserFactory.ExecutorChooser chooser)

Method Summary

Modifier and Type	Method and Description
void	execute(int index, Runnable task) Executes the given task at some time in the future.
Iterator<SingleThreadExecutor>	iterator()
SingleThreadExecutor	next() Returns one of the SingleThreadExecutors managed by this FixedThreadsExecutorGroup.
boolean	shutdownGracefully() Shortcut method for FixedThreadsExecutorGroup.shutdownGracefully(long, TimeUnit) with sensible default values.
boolean	shutdownGracefully(long timeout, TimeUnit unit) Signals all executors that the caller wants them to be shutdown.

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Constructor Detail

DefaultFixedThreadsExecutorGroup

public DefaultFixedThreadsExecutorGroup(SingleThreadExecutor[] children)

DefaultFixedThreadsExecutorGroup

public DefaultFixedThreadsExecutorGroup(SingleThreadExecutor[] children,
                                        ExecutorChooserFactory.ExecutorChooser chooser)

DefaultFixedThreadsExecutorGroup

public DefaultFixedThreadsExecutorGroup(ExecutorService[] executors)

DefaultFixedThreadsExecutorGroup

public DefaultFixedThreadsExecutorGroup(ExecutorService[] executors,
                                        ExecutorChooserFactory.ExecutorChooser chooser)

Method Detail

next

public SingleThreadExecutor next()

Description copied from interface: FixedThreadsExecutorGroup

Returns one of the SingleThreadExecutors managed by this FixedThreadsExecutorGroup.

Specified by:

next in interface FixedThreadsExecutorGroup

execute

public void execute(int index,
                    Runnable task)

Description copied from interface: FixedThreadsExecutorGroup

Executes the given task at some time in the future. The task execute by a specified thread, which is selected by index.

Specified by:

execute in interface FixedThreadsExecutorGroup

Parameters:

index - index for thread chooser

task - the runnable task

shutdownGracefully

public boolean shutdownGracefully()

Description copied from interface: FixedThreadsExecutorGroup

Shortcut method for FixedThreadsExecutorGroup.shutdownGracefully(long, TimeUnit) with sensible default values.

Specified by:

shutdownGracefully in interface FixedThreadsExecutorGroup

Returns:

true if success to shutdown

shutdownGracefully

public boolean shutdownGracefully(long timeout,
                                  TimeUnit unit)

Description copied from interface: FixedThreadsExecutorGroup

Signals all executors that the caller wants them to be shutdown.

Specified by:

shutdownGracefully in interface FixedThreadsExecutorGroup

Parameters:

timeout - the maximum amount of time to wait until the executor is shutdown

unit - the unit of timeout

Returns:

true if success to shutdown

iterator

public Iterator<SingleThreadExecutor> iterator()

Specified by:

iterator in interface Iterable<SingleThreadExecutor>