com.varra.util

Class GlobalThread

java.lang.Object

com.varra.util.SafeThread

com.varra.util.GlobalThread

All Implemented Interfaces:

TimerTaskReceiver, Runnable

@InterfaceAudience.Public
 @InterfaceStability.Evolving
public class GlobalThread
extends SafeThread

An global singleton SafeThread instance.
Created for distribution ease.
Use getGlobalThread(int) to Initialize the the thread with the specified number of threads. Otherwise it uses Executors.newCachedThreadPool() and creates number of the threads on demand.

Version:

1.0

Author:

Rajakrishna V. Reddy

Method Summary

Modifier and Type	Method and Description
static GlobalThread	getGlobalThread() Gets the singleton SafeThread.
static GlobalThread	getGlobalThread(int noOfThreads) Gets the singleton SafeThread.
static GlobalThread	getGlobalThread(int minNoOfThreads, int maxNoOfThreads) Gets the singleton SafeThread.

Methods inherited from class com.varra.util.SafeThread

addTimerTaskListener, getInterval, getListeners, isRunning, onTimerTask, removeTimerTaskListener, run, setInterval, shutdown, start, stop

Methods inherited from class java.lang.Object

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

Method Detail

getGlobalThread

public static GlobalThread getGlobalThread(int minNoOfThreads,
                                           int maxNoOfThreads)

Gets the singleton SafeThread. Instantiates the GlobalThread if not done so far with the number of threads, else returns the existing one.
It uses ThreadPoolExecutor.ThreadPoolExecutor(int, int, long, TimeUnit, java.util.concurrent.BlockingQueue) to create the threads on demand.

Parameters:

minNoOfThreads - the min no of threads

maxNoOfThreads - the max no of threads

Returns:

the global thread

getGlobalThread

public static GlobalThread getGlobalThread(int noOfThreads)

Gets the singleton SafeThread. Instantiates the GlobalThread if not done so far with the number of threads, else returns the existing one.
It uses Executors.newFixedThreadPool(int) to create the threads on demand.

Parameters:

noOfThreads - the no of threads

Returns:

the global thread

getGlobalThread

public static GlobalThread getGlobalThread()

Gets the singleton SafeThread. Instantiates the GlobalThread if not done so far with the number of threads, else returns the existing one.
It uses Executors.newCachedThreadPool() to create the threads on demand.

Returns:

the global thread