io.druid.java.util.common.concurrent

Class Execs

java.lang.Object

io.druid.java.util.common.concurrent.Execs

public class Execs
extends Object

Constructor Summary

Constructors

Constructor and Description
Execs()

Method Summary

Modifier and Type	Method and Description
static ExecutorService	dummy() Returns an ExecutorService which is terminated and shutdown from the beginning and not able to accept any tasks.
static Thread	makeThread(String name, Runnable runnable, boolean isDaemon)
static ThreadFactory	makeThreadFactory(String nameFormat)
static ThreadFactory	makeThreadFactory(String nameFormat, Integer priority)
static ExecutorService	multiThreaded(int threads, String nameFormat)
static ExecutorService	multiThreaded(int threads, String nameFormat, Integer priority)
static ExecutorService	newBlockingSingleThreaded(String nameFormat, int capacity)
static ExecutorService	newBlockingSingleThreaded(String nameFormat, int capacity, Integer priority)
static ScheduledExecutorService	scheduledSingleThreaded(String nameFormat)
static ScheduledExecutorService	scheduledSingleThreaded(String nameFormat, Integer priority)
static ExecutorService	singleThreaded(String nameFormat)
static ExecutorService	singleThreaded(String nameFormat, Integer priority)

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

dummy

public static ExecutorService dummy()

Returns an ExecutorService which is terminated and shutdown from the beginning and not able to accept any tasks.

singleThreaded

public static ExecutorService singleThreaded(@NotNull
                                             String nameFormat)

singleThreaded

public static ExecutorService singleThreaded(@NotNull
                                             String nameFormat,
                                             @Nullable
                                             Integer priority)

multiThreaded

public static ExecutorService multiThreaded(int threads,
                                            @NotNull
                                            String nameFormat)

multiThreaded

public static ExecutorService multiThreaded(int threads,
                                            @NotNull
                                            String nameFormat,
                                            @Nullable
                                            Integer priority)

scheduledSingleThreaded

public static ScheduledExecutorService scheduledSingleThreaded(@NotNull
                                                               String nameFormat)

scheduledSingleThreaded

public static ScheduledExecutorService scheduledSingleThreaded(@NotNull
                                                               String nameFormat,
                                                               @Nullable
                                                               Integer priority)

makeThreadFactory

public static ThreadFactory makeThreadFactory(@NotNull
                                              String nameFormat)

makeThreadFactory

public static ThreadFactory makeThreadFactory(@NotNull
                                              String nameFormat,
                                              @Nullable
                                              Integer priority)

makeThread

public static Thread makeThread(String name,
                                Runnable runnable,
                                boolean isDaemon)

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

newBlockingSingleThreaded

public static ExecutorService newBlockingSingleThreaded(String nameFormat,
                                                        int capacity,
                                                        Integer priority)