public class ForkJoinPoolTest extends JSR166TestCase
JSR166TestCase.AdjustablePolicy, JSR166TestCase.CallableOne, JSR166TestCase.CheckedBarrier, JSR166TestCase.CheckedCallable<T>, JSR166TestCase.CheckedInterruptedCallable<T>, JSR166TestCase.CheckedInterruptedRunnable, JSR166TestCase.CheckedRecursiveAction, JSR166TestCase.CheckedRecursiveTask<T>, JSR166TestCase.CheckedRunnable, JSR166TestCase.LongPossiblyInterruptedRunnable, JSR166TestCase.MediumInterruptedRunnable, JSR166TestCase.MediumPossiblyInterruptedRunnable, JSR166TestCase.MediumRunnable, JSR166TestCase.NoOpCallable, JSR166TestCase.NoOpREHandler, JSR166TestCase.NoOpRunnable, JSR166TestCase.NPETask, JSR166TestCase.RunnableShouldThrow, JSR166TestCase.ShortInterruptedRunnable, JSR166TestCase.ShortRunnable, JSR166TestCase.SimpleThreadFactory, JSR166TestCase.SmallCallable, JSR166TestCase.SmallPossiblyInterruptedRunnable, JSR166TestCase.SmallRunnable, JSR166TestCase.StringTask, JSR166TestCase.ThreadShouldThrow, JSR166TestCase.TrackedCallable, JSR166TestCase.TrackedLongRunnable, JSR166TestCase.TrackedMediumRunnable, JSR166TestCase.TrackedNoOpRunnable, JSR166TestCase.TrackedRunnable, JSR166TestCase.TrackedShortRunnable, JSR166TestCase.TrackedSmallRunnable
eight, expensiveTests, five, four, JAVA_CLASS_VERSION, JAVA_SPECIFICATION_VERSION, LONG_DELAY_MS, m1, m10, m2, m3, m4, m5, m6, MEDIUM_DELAY_MS, nine, one, seven, SHORT_DELAY_MS, six, SIZE, SMALL_DELAY_MS, TEST_STRING, testImplementationDetails, three, two, zero
Constructor and Description |
---|
ForkJoinPoolTest() |
Modifier and Type | Method and Description |
---|---|
void |
testAwaitTermination_timesOut()
awaitTermination on a non-shutdown pool times out
|
void |
testBlockingForkJoinTask()
Pool maintains parallelism when using ManagedBlocker
|
void |
testConstructor1()
Constructor throws if size argument is less than zero
|
void |
testConstructor2()
Constructor throws if factory argument is null
|
void |
testDefaultInitialState()
Successfully constructed pool reports default factory,
parallelism and async mode policies, no active threads or
tasks, and quiescent running state.
|
void |
testDrainTasksTo()
drainTasksTo transfers unexecuted submitted tasks, if present
|
void |
testExecuteNullRunnable()
execute(null runnable) throws NullPointerException
|
void |
testExecuteRunnable()
execute(runnable) runs it to completion
|
void |
testGetParallelism()
getParallelism returns size set in constructor
|
void |
testGetPoolSize()
getPoolSize returns number of started workers.
|
void |
testInterruptedSubmit()
submit(callable).get() throws InterruptedException if interrupted
|
void |
testInvokeAll1()
invokeAll(null) throws NullPointerException
|
void |
testInvokeAll2()
invokeAll(empty collection) returns empty collection
|
void |
testInvokeAll3()
invokeAll(c) throws NullPointerException if c has null elements
|
void |
testInvokeAll4()
get of returned element of invokeAll(c) throws
ExecutionException on failed task
|
void |
testInvokeAll5()
invokeAll(c) returns results of all completed tasks in c
|
void |
testInvokeAny1()
invokeAny(null) throws NullPointerException
|
void |
testInvokeAny2()
invokeAny(empty collection) throws IllegalArgumentException
|
void |
testInvokeAny3()
invokeAny(c) throws NullPointerException if c has a single null element
|
void |
testInvokeAny4()
invokeAny(c) throws NullPointerException if c has null elements
|
void |
testInvokeAny5()
invokeAny(c) throws ExecutionException if no task in c completes
|
void |
testInvokeAny6()
invokeAny(c) returns result of some task in c if at least one completes
|
void |
testIsQuiescent()
After invoking a single task, isQuiescent eventually becomes
true, at which time queues are empty, threads are not active,
the task has completed successfully, and construction
parameters continue to hold
|
void |
testPollSubmission()
pollSubmission returns unexecuted submitted task, if present
|
void |
testSetUncaughtExceptionHandler()
setUncaughtExceptionHandler changes handler for uncaught exceptions.
|
void |
testSubmitAfterShutdown()
A task submitted after shutdown is rejected
|
void |
testSubmitCallable()
Completed submit(callable) returns result
|
void |
testSubmitEE()
get of submit(callable) throws ExecutionException if callable
throws exception
|
void |
testSubmitFailedPrivilegedExceptionAction()
A submitted failed privileged exception action reports exception
|
void |
testSubmitForkJoinTask()
Completed submit(ForkJoinTask) returns result
|
void |
testSubmitNullCallable()
submit(null callable) throws NullPointerException
|
void |
testSubmitPrivilegedAction()
A submitted privileged action runs to completion
|
void |
testSubmitPrivilegedExceptionAction()
A submitted privileged exception action runs to completion
|
void |
testSubmitRunnable()
Completed submit(runnable) returns successfully
|
void |
testSubmitRunnable2()
Completed submit(runnable, result) returns result
|
void |
testTimedInvokeAll1()
timed invokeAll(null) throws NullPointerException
|
void |
testTimedInvokeAll2()
timed invokeAll(empty collection) returns empty collection
|
void |
testTimedInvokeAll3()
timed invokeAll(c) throws NullPointerException if c has null elements
|
void |
testTimedInvokeAll4()
get of returned element of invokeAll(c) throws exception on failed task
|
void |
testTimedInvokeAll5()
timed invokeAll(c) returns results of all completed tasks in c
|
void |
testTimedInvokeAllNullTimeUnit()
timed invokeAll(null time unit) throws NullPointerException
|
void |
testTimedInvokeAny1()
timed invokeAny(null) throws NullPointerException
|
void |
testTimedInvokeAny2()
timed invokeAny(empty collection) throws IllegalArgumentException
|
void |
testTimedInvokeAny3()
timed invokeAny(c) throws NullPointerException if c has null elements
|
void |
testTimedInvokeAny4()
timed invokeAny(c) throws ExecutionException if no task completes
|
void |
testTimedInvokeAny5()
timed invokeAny(c) returns result of some task in c
|
void |
testTimedInvokeAnyNullTimeUnit()
timed invokeAny(null time unit) throws NullPointerException
|
addNamedTestClasses, assertIteratorExhausted, assertThrows, atLeastJava10, atLeastJava6, atLeastJava7, atLeastJava8, atLeastJava9, await, await, await, awaiter, countDowner, getShortDelay, jdk8ParameterizedTestSuite, latchAwaitingStringTask, newTestSuite, parameterizedTestSuite, permissivePolicy, possiblyInterruptedRunnable, runBare, runTest, runTestProfiled, runWithoutPermissions, runWithPermissions, runWithSecurityManagerWithPermissions, setDelays, setUp, shouldThrow, shouldThrow, tearDown, testMethodNames, threadAssertEquals, threadAssertEquals, threadAssertFalse, threadAssertNull, threadAssertSame, threadAssertTrue, threadFail, threadRecordFailure, threadShouldThrow, threadShouldThrow, threadUnexpectedException, trackedRunnable
public void testDefaultInitialState()
public void testConstructor1()
public void testConstructor2()
public void testGetParallelism()
public void testGetPoolSize()
public void testAwaitTermination_timesOut() throws InterruptedException
InterruptedException
public void testSetUncaughtExceptionHandler() throws InterruptedException
InterruptedException
public void testIsQuiescent() throws Exception
Exception
public void testSubmitForkJoinTask() throws Throwable
Throwable
public void testSubmitAfterShutdown()
public void testBlockingForkJoinTask() throws Throwable
Throwable
public void testPollSubmission()
public void testDrainTasksTo()
public void testExecuteRunnable() throws Throwable
Throwable
public void testSubmitCallable() throws Throwable
Throwable
public void testSubmitRunnable() throws Throwable
Throwable
public void testSubmitRunnable2() throws Throwable
Throwable
public void testSubmitPrivilegedAction() throws Exception
Exception
public void testSubmitPrivilegedExceptionAction() throws Exception
Exception
public void testSubmitFailedPrivilegedExceptionAction() throws Exception
Exception
public void testExecuteNullRunnable()
public void testSubmitNullCallable()
public void testInterruptedSubmit() throws InterruptedException
InterruptedException
public void testSubmitEE() throws Throwable
Throwable
public void testInvokeAny1() throws Throwable
Throwable
public void testInvokeAny2() throws Throwable
Throwable
public void testInvokeAny3() throws Throwable
Throwable
public void testInvokeAny4() throws Throwable
Throwable
public void testInvokeAny5() throws Throwable
Throwable
public void testInvokeAny6() throws Throwable
Throwable
public void testInvokeAll1() throws Throwable
Throwable
public void testInvokeAll2() throws InterruptedException
InterruptedException
public void testInvokeAll3() throws InterruptedException
InterruptedException
public void testInvokeAll4() throws Throwable
Throwable
public void testInvokeAll5() throws Throwable
Throwable
public void testTimedInvokeAny1() throws Throwable
Throwable
public void testTimedInvokeAnyNullTimeUnit() throws Throwable
Throwable
public void testTimedInvokeAny2() throws Throwable
Throwable
public void testTimedInvokeAny3() throws Throwable
Throwable
public void testTimedInvokeAny4() throws Throwable
Throwable
public void testTimedInvokeAny5() throws Throwable
Throwable
public void testTimedInvokeAll1() throws Throwable
Throwable
public void testTimedInvokeAllNullTimeUnit() throws Throwable
Throwable
public void testTimedInvokeAll2() throws InterruptedException
InterruptedException
public void testTimedInvokeAll3() throws InterruptedException
InterruptedException
public void testTimedInvokeAll4() throws Throwable
Throwable