ForkJoinPool, DefaultParallelExecutionConfigurationStrategy
| Modifier and Type | Class and Description |
|---|---|
| pack-priv class | |
| pack-priv static interface | |
| pack-priv static class | |
| pack-priv static class | |
| pack-priv static class |
| Modifier and Type | Field and Description |
|---|---|
| pack-priv final ForkJoinPool | |
| private final int | |
| private final ForkJoinPoolHierarchicalTestExecutorService. | |
| private final ThreadLocal |
| Access | Constructor and Description |
|---|---|
| public | ForkJoinPoolHierarchicalTestExecutorService(ConfigurationParameters configurationParameters)
Create a new |
| public | ForkJoinPoolHierarchicalTestExecutorService(ParallelExecutionConfiguration configuration)
Create a new |
| pack-priv | ForkJoinPoolHierarchicalTestExecutorService(ParallelExecutionConfiguration configuration, ForkJoinPoolHierarchicalTestExecutorService.
|
| forkJoinPool | back to summary |
|---|---|
| pack-priv final ForkJoinPool forkJoinPool | |
| parallelism | back to summary |
|---|---|
| private final int parallelism | |
| taskEventListener | back to summary |
|---|---|
| private final ForkJoinPoolHierarchicalTestExecutorService. | |
| threadLocks | back to summary |
|---|---|
| private final ThreadLocal<ForkJoinPoolHierarchicalTestExecutorService. | |
| ForkJoinPoolHierarchicalTestExecutorService | back to summary |
|---|---|
| public ForkJoinPoolHierarchicalTestExecutorService(ConfigurationParameters configurationParameters) Create a new | |
| ForkJoinPoolHierarchicalTestExecutorService | back to summary |
|---|---|
| public ForkJoinPoolHierarchicalTestExecutorService(ParallelExecutionConfiguration configuration) Create a new | |
| ForkJoinPoolHierarchicalTestExecutorService | back to summary |
|---|---|
| pack-priv ForkJoinPoolHierarchicalTestExecutorService(ParallelExecutionConfiguration configuration, ForkJoinPoolHierarchicalTestExecutorService. | |
| close | back to summary |
|---|---|
| public void close() Implements org. Doc from org. Close this service and let it perform any required cleanup work. For example, thread-based implementations should usually close their thread pools in this method.
| |
| createConfiguration | back to summary |
|---|---|
| private static ParallelExecutionConfiguration createConfiguration(ConfigurationParameters configurationParameters) | |
| createForkJoinPool | back to summary |
|---|---|
| private ForkJoinPool createForkJoinPool(ParallelExecutionConfiguration configuration) | |
| executeSync | back to summary |
|---|---|
| private void executeSync(Deque<ForkJoinPoolHierarchicalTestExecutorService. | |
| forkConcurrentTasks | back to summary |
|---|---|
| private void forkConcurrentTasks(List<? extends HierarchicalTestExecutorService. | |
| invokeAll | back to summary |
|---|---|
| public void invokeAll(List<? extends HierarchicalTestExecutorService. Implements org. Doc from org. Invoke all supplied test tasks and block until their execution has finished. Implementations may execute one or multiple of the supplied tasks in parallel as long as their execution mode is concurrent. Implementations must generally acquire and release each task's resource lock before and after its execution unless they execute all tests in the same thread which upholds the same guarantees.
| |
| isAlreadyRunningInForkJoinPool | back to summary |
|---|---|
| private boolean isAlreadyRunningInForkJoinPool() | |
| joinConcurrentTasksInReverseOrderToEnableWorkStealing | back to summary |
|---|---|
| private void joinConcurrentTasksInReverseOrderToEnableWorkStealing(Deque<ForkJoinPoolHierarchicalTestExecutorService. | |
| requiresGlobalReadWriteLock | back to summary |
|---|---|
| private static boolean requiresGlobalReadWriteLock(HierarchicalTestExecutorService. | |
| resubmitDeferredTasks | back to summary |
|---|---|
| private void resubmitDeferredTasks() | |
| submit | back to summary |
|---|---|
| public Future Implements org. Doc from org. Submit the supplied test task to be executed by this service. Implementations may execute the task asynchronously as long as its execution mode is concurrent. Implementations must generally acquire and release the task's resource lock before and after its execution unless they execute all tests in the same thread which upholds the same guarantees.
| |
| Modifier and Type | Field and Description |
|---|---|
| private static final long | |
| private final HierarchicalTestExecutorService. |
| Access | Constructor and Description |
|---|---|
| pack-priv |
| Modifier and Type | Method and Description |
|---|---|
| public boolean | exec()
Implements abstract java. Immediately performs the base action of this task and returns true if, upon return from this method, this task is guaranteed to have completed. |
| pack-priv void | |
| public final Void | Returns: null alwaysImplements abstract java. Always returns |
| protected final void | setRawResult(Void mustBeNull)
Implements abstract java. Requires null completion value. |
| public String |
| serialVersionUID | back to summary |
|---|---|
| private static final long serialVersionUID Hides java. | |
| testTask | back to summary |
|---|---|
| private final HierarchicalTestExecutorService. | |
| ExclusiveTask | back to summary |
|---|---|
| pack-priv ExclusiveTask(HierarchicalTestExecutorService. | |
| exec | back to summary |
|---|---|
| public boolean exec() Implements abstract java. Doc from java. Immediately performs the base action of this task and returns true if, upon return from this method, this task is guaranteed to have completed. This method may return false otherwise, to indicate that this task is not necessarily complete (or is not known to be complete), for example in asynchronous actions that require explicit invocations of completion methods. This method may also throw an (unchecked) exception to indicate abnormal exit. This method is designed to support extensions, and should not in general be called otherwise.
| |
| execSync | back to summary |
|---|---|
| pack-priv void execSync() | |
| getRawResult | back to summary |
|---|---|
| public final Void getRawResult() Implements abstract java. Always returns | |
| setRawResult | back to summary |
|---|---|
| protected final void setRawResult(Void mustBeNull) Implements abstract java. Requires null completion value.
| |
| toString | back to summary |
|---|---|
| public String toString() Overrides java. Doc from java. Returns a string representation of the object.
Satisfying this method's contract implies a non-
| |
| Modifier and Type | Field and Description |
|---|---|
| public static final ForkJoinPoolHierarchicalTestExecutorService. |
| Modifier and Type | Method and Description |
|---|---|
| public void |
| NOOP | back to summary |
|---|---|
| public static final ForkJoinPoolHierarchicalTestExecutorService. | |
| deferred | back to summary |
|---|---|
| public void deferred(HierarchicalTestExecutorService. | |
| Modifier and Type | Class and Description |
|---|---|
| pack-priv static interface |
| Modifier and Type | Field and Description |
|---|---|
| private final List | |
| private final Deque |
| Access | Constructor and Description |
|---|---|
| pack-priv |
| Modifier and Type | Method and Description |
|---|---|
| pack-priv void | |
| pack-priv boolean | |
| pack-priv ForkJoinPoolHierarchicalTestExecutorService. |
| deferredTasks | back to summary |
|---|---|
| private final List<ForkJoinPoolHierarchicalTestExecutorService. | |
| locks | back to summary |
|---|---|
| private final Deque<ResourceLock> locks | |
| ThreadLock | back to summary |
|---|---|
| pack-priv ThreadLock() | |
| addDeferredTask | back to summary |
|---|---|
| pack-priv void addDeferredTask(ForkJoinPoolHierarchicalTestExecutorService. | |
| areAllHeldLocksCompatibleWith | back to summary |
|---|---|
| pack-priv boolean areAllHeldLocksCompatibleWith(ResourceLock lock) | |
| withNesting | back to summary |
|---|---|
| pack-priv ForkJoinPoolHierarchicalTestExecutorService. | |
| Modifier and Type | Method and Description |
|---|---|
| public void | close()
Redeclares java. Closes this resource, relinquishing any underlying resources. |
| close | back to summary |
|---|---|
| public void close() Redeclares java. Doc from java. Closes this resource, relinquishing any underlying resources.
This method is invoked automatically on objects managed by the
| |
| Access | Constructor and Description |
|---|---|
| pack-priv |
| WorkerThread | back to summary |
|---|---|
| pack-priv WorkerThread(ForkJoinPool pool, ClassLoader contextClassLoader) | |
| Modifier and Type | Field and Description |
|---|---|
| private final ClassLoader |
| Access | Constructor and Description |
|---|---|
| pack-priv |
| Modifier and Type | Method and Description |
|---|---|
| public ForkJoinWorkerThread | newThread(ForkJoinPool pool)
Implements java. Returns a new worker thread operating in the given pool. |
| contextClassLoader | back to summary |
|---|---|
| private final ClassLoader contextClassLoader | |
| WorkerThreadFactory | back to summary |
|---|---|
| pack-priv WorkerThreadFactory() | |
| newThread | back to summary |
|---|---|
| public ForkJoinWorkerThread newThread(ForkJoinPool pool) Implements java. Doc from java. 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
| |