io.druid.concurrent

Class Execs

java.lang.Object

io.druid.concurrent.Execs

public class Execs
extends Object

Constructor Summary

Constructors

Constructor and Description
Execs()

Method Summary

Methods

Modifier and Type	Method and Description
static ThreadFactory	makeThreadFactory(String nameFormat)
static ExecutorService	multiThreaded(int threads, String nameFormat)
static ExecutorService	newBlockingSingleThreaded(String nameFormat, int capacity)
static ScheduledExecutorService	scheduledSingleThreaded(String nameFormat)
static ExecutorService	singleThreaded(String nameFormat)

Methods inherited from class java.lang.Object

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

Constructor Detail

Execs

public Execs()

Method Detail

singleThreaded

public static ExecutorService singleThreaded(String nameFormat)

multiThreaded

public static ExecutorService multiThreaded(int threads,
                            String nameFormat)

scheduledSingleThreaded

public static ScheduledExecutorService scheduledSingleThreaded(String nameFormat)

makeThreadFactory

public static ThreadFactory makeThreadFactory(String nameFormat)

newBlockingSingleThreaded

public static ExecutorService newBlockingSingleThreaded(String nameFormat,
                                        int capacity)

Parameters:

nameFormat - nameformat for threadFactory

capacity - maximum capacity after which the executorService will block on accepting new tasks

Returns:

ExecutorService which blocks accepting new tasks when the capacity reached