Package org.apache.ofbiz.base.concurrent

Class ExecutionPool

java.lang.Object

org.apache.ofbiz.base.concurrent.ExecutionPool

public final class ExecutionPool
extends java.lang.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 java.util.concurrent.ExecutorService	GLOBAL_BATCH
static java.util.concurrent.ForkJoinPool	GLOBAL_FORK_JOIN
static java.lang.String	module

Constructor Summary

Constructors

Constructor	Description
ExecutionPool()

Method Summary

Modifier and Type	Method	Description
static void	addPulse(ExecutionPool.Pulse pulse)
static <F> java.util.List<F>	getAllFutures(java.util.Collection<java.util.concurrent.Future<F>> futureList)
static java.util.concurrent.ScheduledExecutorService	getScheduledExecutor(java.lang.ThreadGroup group, java.lang.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 Detail

module

public static final java.lang.String module

GLOBAL_BATCH

public static final java.util.concurrent.ExecutorService GLOBAL_BATCH

GLOBAL_FORK_JOIN

public static final java.util.concurrent.ForkJoinPool GLOBAL_FORK_JOIN

Constructor Detail

ExecutionPool

public ExecutionPool()

Method Detail

getScheduledExecutor

public static java.util.concurrent.ScheduledExecutorService getScheduledExecutor(java.lang.ThreadGroup group,
                                                                                 java.lang.String namePrefix,
                                                                                 int threadCount,
                                                                                 long keepAliveSeconds,
                                                                                 boolean preStart)

getAllFutures

public static <F> java.util.List<F> getAllFutures(java.util.Collection<java.util.concurrent.Future<F>> futureList)

addPulse

public static void addPulse(ExecutionPool.Pulse pulse)

removePulse

public static void removePulse(ExecutionPool.Pulse pulse)