Package org.hibernate.search.batchindexing

Class Executors

java.lang.Object

org.hibernate.search.batchindexing.Executors

public class Executors
extends Object

Helper class to create threads; these threads are grouped and named to be identified in a profiler.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	Executors.BlockPolicy	A handler for rejected tasks that will have the caller block until space is available.

Field Summary

Fields

Modifier and Type	Field	Description
static final int	QUEUE_MAX_LENGTH

Constructor Summary

Constructors

Constructor	Description
Executors()

Method Summary

Modifier and Type	Method	Description
static ThreadPoolExecutor	newFixedThreadPool(int threads, String groupname)	Creates a new fixed size ThreadPoolExecutor.
static ThreadPoolExecutor	newFixedThreadPool(int threads, String groupname, int queueSize)	Creates a new fixed size ThreadPoolExecutor

Methods inherited from class java.lang.Object

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

Field Details

QUEUE_MAX_LENGTH

public static final int QUEUE_MAX_LENGTH

See Also:

• Constant Field Values

Constructor Details

Executors

public Executors()

Method Details

newFixedThreadPool

public static ThreadPoolExecutor newFixedThreadPool(int threads,
 String groupname)

Creates a new fixed size ThreadPoolExecutor. It's using a blockingqueue of maximum 1000 elements and the rejection policy is set to CallerRunsPolicy for the case the queue is full. These settings are required to cap the queue, to make sure the timeouts are reasonable for most jobs.

Parameters:

threads - the number of threads

groupname - a label to identify the threadpool; useful for profiling.

Returns:

the new ExecutorService

newFixedThreadPool

public static ThreadPoolExecutor newFixedThreadPool(int threads,
 String groupname,
 int queueSize)

Creates a new fixed size ThreadPoolExecutor

Parameters:

threads - the number of threads

groupname - a label to identify the threadpool; useful for profiling.

queueSize - the size of the queue to store Runnables when all threads are busy

Returns:

the new ExecutorService