Package org.apache.drill.exec.rpc

Class NamedThreadFactory

java.lang.Object

org.apache.drill.exec.rpc.NamedThreadFactory

All Implemented Interfaces:

ThreadFactory

public class NamedThreadFactory
extends Object
implements ThreadFactory

ThreadFactory for ExecutorServices that names threads sequentially. Creates Threads named with the prefix specified at construction time. Created threads have the daemon bit set and priority Thread.MAX_PRIORITY.

An instance creates names with an instance-specific prefix suffixed with sequential integers.

Concurrency: See newThread(java.lang.Runnable).

Constructor Summary

Constructors

Constructor	Description
NamedThreadFactory(String prefix)	Constructor.

Method Summary

Modifier and Type	Method	Description
Thread	newThread(Runnable runnable)	Creates a sequentially named thread running a given Runnable.

Methods inherited from class java.lang.Object

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

Constructor Details

NamedThreadFactory

public NamedThreadFactory(String prefix)

Constructor.

Parameters:

prefix - the string prefix that will be used to name threads created by this factory

Method Details

newThread

public Thread newThread(Runnable runnable)

Creates a sequentially named thread running a given Runnable.

The thread's name will be this instance's prefix concatenated with this instance's next^* sequential integer.

Concurrency: Thread-safe.

(Concurrent calls get different numbers. Calls started after other calls complete get later/higher numbers than those other calls.

*However, for concurrent calls, the order of numbers is not defined.)

Specified by:

newThread in interface ThreadFactory