org.apache.giraph.utils

Class ThreadUtils

java.lang.Object

org.apache.giraph.utils.ThreadUtils

public class ThreadUtils
extends Object

Utility class for thread related functions.

Method Summary

Modifier and Type	Method and Description
static ThreadFactory	createThreadFactory(String nameFormat) Creates new thread factory with specified thread name format.
static ThreadFactory	createThreadFactory(String nameFormat, Thread.UncaughtExceptionHandler exceptionHandler) Creates new thread factory with specified thread name format.
static Thread	startThread(Runnable runnable, String threadName) Start thread with specified name and runnable, and make it daemon
static Thread	startThread(Runnable runnable, String threadName, Thread.UncaughtExceptionHandler handler) Start thread with specified name, runnable and exception handler, and make it daemon
static <T> Future<T>	submitToExecutor(ExecutorService executorService, Callable<T> callable, Thread.UncaughtExceptionHandler uncaughtExceptionHandler) Submit a callable to executor service, ensuring any exceptions are caught with provided exception handler.
static boolean	trySleep(long millis) Sleep for specified milliseconds, logging and ignoring interrupted exceptions

Methods inherited from class java.lang.Object

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

Method Detail

createThreadFactory

public static ThreadFactory createThreadFactory(String nameFormat,
                                                Thread.UncaughtExceptionHandler exceptionHandler)

Creates new thread factory with specified thread name format.

Parameters:

nameFormat - defines naming format for threads created by thread factory

exceptionHandler - handles uncaught exceptions in all threads produced created thread factory

Returns:

new thread factory with specified thread name format and exception handler.

createThreadFactory

public static ThreadFactory createThreadFactory(String nameFormat)

Creates new thread factory with specified thread name format.

Parameters:

nameFormat - defines naming format for threads created by thread factory

Returns:

new thread factory with specified thread name format

submitToExecutor

public static <T> Future<T> submitToExecutor(ExecutorService executorService,
                                             Callable<T> callable,
                                             Thread.UncaughtExceptionHandler uncaughtExceptionHandler)

Submit a callable to executor service, ensuring any exceptions are caught with provided exception handler. When using submit(), UncaughtExceptionHandler which is set on ThreadFactory isn't used, so we need this utility.

Type Parameters:

T - Type of callable result

Parameters:

executorService - Executor service to submit callable to

callable - Callable to submit

uncaughtExceptionHandler - Handler for uncaught exceptions in callable

Returns:

Future for callable

startThread

public static Thread startThread(Runnable runnable,
                                 String threadName)

Start thread with specified name and runnable, and make it daemon

Parameters:

threadName - Name of the thread

runnable - Runnable to execute

Returns:

Thread

startThread

public static Thread startThread(Runnable runnable,
                                 String threadName,
                                 Thread.UncaughtExceptionHandler handler)

Start thread with specified name, runnable and exception handler, and make it daemon

Parameters:

runnable - Runnable to execute

threadName - Name of the thread

handler - Exception handler

Returns:

Thread

trySleep

public static boolean trySleep(long millis)

Sleep for specified milliseconds, logging and ignoring interrupted exceptions

Parameters:

millis - How long to sleep for

Returns:

Whether the sleep was successful or the thread was interrupted