Package org.apache.ofbiz.base.concurrent

Class ExecutionPool

java.lang.Object

org.apache.ofbiz.base.concurrent.ExecutionPool

public final class ExecutionPool
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ExecutionPool.ExecutionPoolPulseWorker
protected static class	ExecutionPool.ExecutionPoolThreadFactory
static class	ExecutionPool.Pulse

Field Summary

Fields

Modifier and Type	Field	Description
static final ExecutorService	GLOBAL_BATCH
static final ForkJoinPool	GLOBAL_FORK_JOIN

Constructor Summary

Constructors

Constructor	Description
ExecutionPool()

Method Summary

Modifier and Type	Method	Description
static void	addPulse(ExecutionPool.Pulse pulse)
static <F> List<F>	getAllFutures(Collection<Future<F>> futureList)
static ScheduledExecutorService	getScheduledExecutor(ThreadGroup group, String namePrefix, int threadCount, long keepAliveSeconds, boolean preStart)
static void	removePulse(ExecutionPool.Pulse pulse)

Methods inherited from class java.lang.Object

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

Field Details

GLOBAL_BATCH

public static final ExecutorService GLOBAL_BATCH

GLOBAL_FORK_JOIN

public static final ForkJoinPool GLOBAL_FORK_JOIN

Constructor Details

ExecutionPool

public ExecutionPool()

Method Details

getScheduledExecutor

public static ScheduledExecutorService getScheduledExecutor(ThreadGroup group,
 String namePrefix,
 int threadCount,
 long keepAliveSeconds,
 boolean preStart)

getAllFutures

public static <F> List<F> getAllFutures(Collection<Future<F>> futureList)

addPulse

public static void addPulse(ExecutionPool.Pulse pulse)

removePulse

public static void removePulse(ExecutionPool.Pulse pulse)