alluxio.concurrent.jsr

Class ForkJoinPool.AlluxioForkJoinWorkerThreadFactory

java.lang.Object

alluxio.concurrent.jsr.ForkJoinPool.AlluxioForkJoinWorkerThreadFactory

All Implemented Interfaces:

ForkJoinPool.ForkJoinWorkerThreadFactory

Enclosing class:

ForkJoinPool

public static final class ForkJoinPool.AlluxioForkJoinWorkerThreadFactory
extends Object
implements ForkJoinPool.ForkJoinWorkerThreadFactory

Default ForkJoinWorkerThreadFactory implementation; creates a new ForkJoinWorkerThread using the system class loader as the thread context class loader.

Constructor Summary

Constructors

Constructor and Description
AlluxioForkJoinWorkerThreadFactory(String threadNameFormat, boolean isDaemon) Creates a new thread-factory for ForkJoinPool.

Method Summary

Modifier and Type	Method and Description
ForkJoinWorkerThread	newThread(ForkJoinPool pool) Returns a new worker thread operating in the given pool.

Methods inherited from class java.lang.Object

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

Constructor Detail

AlluxioForkJoinWorkerThreadFactory

public AlluxioForkJoinWorkerThreadFactory(String threadNameFormat,
                                          boolean isDaemon)

Creates a new thread-factory for ForkJoinPool.

Parameters:

threadNameFormat - thread name format

isDaemon - is daemon

Method Detail

newThread

public final ForkJoinWorkerThread newThread(ForkJoinPool pool)

Description copied from interface: ForkJoinPool.ForkJoinWorkerThreadFactory

Returns a new worker thread operating in the given pool. Returning null or throwing an exception may result in tasks never being executed. If this method throws an exception, it is relayed to the caller of the method (for example execute) causing attempted thread creation. If this method returns null or throws an exception, it is not retried until the next attempted creation (for example another call to execute).

Specified by:

newThread in interface ForkJoinPool.ForkJoinWorkerThreadFactory

Parameters:

pool - the pool this thread works in

Returns:

the new worker thread, or null if the request to create a thread is rejected