public class CountedCompleterTest extends JSR166TestCase
Modifier and Type | Class and Description |
---|---|
static class |
CountedCompleterTest.FJException |
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 |
---|
CountedCompleterTest() |
Modifier and Type | Method and Description |
---|---|
void |
testAbnormalForkGet()
get of a forked task throws exception when task completes abnormally
|
void |
testAbnormalForkGetSingleton()
get of a forked task throws exception when task completes abnormally
|
void |
testAbnormalForkJoin()
join of a forked task throws exception when task completes abnormally
|
void |
testAbnormalForkJoinSingleton()
join of a forked task throws exception when task completes abnormally
|
void |
testAbnormalForkQuietlyJoin()
quietlyJoin of a forked task returns when task completes abnormally
|
void |
testAbnormalForkQuietlyJoinSingleton()
quietlyJoin of a forked task returns when task completes abnormally
|
void |
testAbnormalForkTimedGet()
timed get of a forked task throws exception when task completes abnormally
|
void |
testAbnormalForkTimedGetSingleton()
timed get of a forked task throws exception when task completes abnormally
|
void |
testAbnormalInvoke()
invoke task throws exception when task completes abnormally
|
void |
testAbnormalInvokeAll1()
invokeAll(tasks) with 1 argument throws exception if task does
|
void |
testAbnormalInvokeAll1Singleton()
invokeAll(tasks) with 1 argument throws exception if task does
|
void |
testAbnormalInvokeAll2()
invokeAll(t1, t2) throw exception if any task does
|
void |
testAbnormalInvokeAll2Singleton()
invokeAll(t1, t2) throw exception if any task does
|
void |
testAbnormalInvokeAll3()
invokeAll(tasks) with > 2 argument throws exception if any task does
|
void |
testAbnormalInvokeAll3Singleton()
invokeAll(tasks) with > 2 argument throws exception if any task does
|
void |
testAbnormalInvokeAllCollection()
invokeAll(collection) throws exception if any task does
|
void |
testAbnormalInvokeAllCollectionSingleton()
invokeAll(collection) throws exception if any task does
|
void |
testAbnormalInvokeSingleton()
invoke task throws exception when task completes abnormally
|
void |
testAbnormalQuietlyInvoke()
quietlyInvoke task returns when task completes abnormally
|
void |
testAbnormalQuietlyInvokeSingleton()
quietlyInvoke task returns when task completes abnormally
|
void |
testAddToPendingCount()
addToPendingCount adds to the reported pending count
|
void |
testCancelledForkGet()
get of a forked task throws exception when task cancelled
|
void |
testCancelledForkGetSingleton()
get of a forked task throws exception when task cancelled
|
void |
testCancelledForkJoin()
join of a forked task throws exception when task cancelled
|
void |
testCancelledForkJoinSingleton()
join of a forked task throws exception when task cancelled
|
void |
testCancelledForkQuietlyJoin()
quietlyJoin of a forked task returns when task cancelled
|
void |
testCancelledForkQuietlyJoinSingleton()
quietlyJoin of a forked task returns when task cancelled
|
void |
testCancelledForkTimedGet()
timed get of a forked task throws exception when task cancelled
|
void |
testCancelledForkTimedGetSingleton()
timed get of a forked task throws exception when task cancelled
|
void |
testCancelledInvoke()
invoke task throws exception when task cancelled
|
void |
testCancelledInvokeSingleton()
invoke task throws exception when task cancelled
|
void |
testCompareAndSetPendingCount()
compareAndSetPendingCount compares and sets the reported
pending count
|
void |
testComplete()
A newly constructed CountedCompleter is not completed;
complete() causes completion. pendingCount is ignored.
|
void |
testCompleteExceptionally_null()
completeExceptionally(null) surprisingly has the same effect as
completeExceptionally(new RuntimeException())
|
void |
testCompleteExceptionally()
completeExceptionally completes exceptionally
|
void |
testCompleteExceptionally2()
invoke task throws exception after invoking completeExceptionally
|
void |
testCompleteExceptionallySingleton()
invoke task throws exception after invoking completeExceptionally
|
void |
testDecrementPendingCountUnlessZero()
decrementPendingCountUnlessZero decrements reported pending
count unless zero
|
void |
testFirstComplete()
firstComplete returns this if pending count is zero else null
|
void |
testForkGet()
get of a forked task returns when task completes
|
void |
testForkGetSingleton()
get of a forked task returns when task completes
|
void |
testForkHelpQuiesce()
helpQuiesce returns when tasks are complete.
|
void |
testForkHelpQuiesceSingleton()
helpQuiesce returns when tasks are complete.
|
void |
testForkJoin()
join of a forked task returns when task completes
|
void |
testForkJoinSingleton()
join of a forked task returns when task completes
|
void |
testForkQuietlyJoin()
quietlyJoin of a forked task returns when task completes
|
void |
testForkQuietlyJoinSingleton()
quietlyJoin of a forked task returns when task completes
|
void |
testForkTimedGet()
timed get of a forked task returns when task completes
|
void |
testForkTimedGetNPE()
timed get with null time unit throws NPE
|
void |
testForkTimedGetNPESingleton()
timed get with null time unit throws NPE
|
void |
testForkTimedGetSingleton()
timed get of a forked task returns when task completes
|
void |
testGetCompleter()
getCompleter returns parent or null if at root
|
void |
testGetPool()
getPool of executing task returns its pool
|
void |
testGetPool2()
getPool of non-FJ task returns null
|
void |
testGetRoot()
getRoot returns self if no parent, else parent's root
|
void |
testGetSurplusQueuedTaskCount()
getSurplusQueuedTaskCount returns > 0 when
there are more tasks than threads
|
void |
testInForkJoinPool()
inForkJoinPool of executing task returns true
|
void |
testInForkJoinPool2()
inForkJoinPool of non-FJ task returns false
|
void |
testInvoke()
invoke returns when task completes normally.
|
void |
testInvokeAll1()
invokeAll(tasks) with 1 argument invokes task
|
void |
testInvokeAll1Singleton()
invokeAll(tasks) with 1 argument invokes task
|
void |
testInvokeAll2()
invokeAll(t1, t2) invokes all task arguments
|
void |
testInvokeAll2Singleton()
invokeAll(t1, t2) invokes all task arguments
|
void |
testInvokeAll3()
invokeAll(tasks) with > 2 argument invokes tasks
|
void |
testInvokeAll3Singleton()
invokeAll(tasks) with > 2 argument invokes tasks
|
void |
testInvokeAllCollection()
invokeAll(collection) invokes all tasks in the collection
|
void |
testInvokeAllCollectionSingleton()
invokeAll(collection) invokes all tasks in the collection
|
void |
testInvokeAllNPE()
invokeAll(tasks) with any null task throws NPE
|
void |
testInvokeAllNPESingleton()
invokeAll(tasks) with any null task throws NPE
|
void |
testInvokeSingleton()
invoke returns when task completes normally.
|
void |
testNextComplete()
firstComplete.nextComplete returns parent if pending count is
zero else null
|
void |
testPeekNextLocalTask()
peekNextLocalTask returns most recent unexecuted task.
|
void |
testPeekNextLocalTaskAsync()
peekNextLocalTask returns least recent unexecuted task in async mode
|
void |
testPollNextLocalTask()
pollNextLocalTask returns most recent unexecuted task without
executing it
|
void |
testPollNextLocalTaskAsync()
pollNextLocalTask returns least recent unexecuted task without
executing it, in async mode
|
void |
testPollTask()
pollTask returns an unexecuted task without executing it
|
void |
testPollTaskAsync()
pollTask returns an unexecuted task without executing it, in
async mode
|
void |
testPropagateCompletion()
propagateCompletion decrements pending count unless zero, in
which case causes completion, without invoking onCompletion
|
void |
testQuietlyCompleteRoot()
quietlyCompleteRoot completes root task and only root task
|
void |
testQuietlyInvoke()
quietlyInvoke task returns when task completes normally.
|
void |
testQuietlyInvokeSingleton()
quietlyInvoke task returns when task completes normally.
|
void |
testSetPendingCount()
setPendingCount sets the reported pending count
|
void |
testSetRawResult()
setRawResult(null) succeeds
|
void |
testTryComplete()
tryComplete decrements pending count unless zero, in which case
causes completion
|
void |
testTryUnfork()
tryUnfork returns true for most recent unexecuted task,
and suppresses execution
|
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 testComplete()
public void testCompleteExceptionally()
public void testCompleteExceptionally_null()
public void testSetPendingCount()
public void testAddToPendingCount()
public void testDecrementPendingCountUnlessZero()
public void testCompareAndSetPendingCount()
public void testGetCompleter()
public void testGetRoot()
public void testTryComplete()
public void testPropagateCompletion()
public void testFirstComplete()
public void testNextComplete()
public void testQuietlyCompleteRoot()
public void testInvoke()
public void testQuietlyInvoke()
public void testForkJoin()
public void testForkGet()
public void testForkTimedGet()
public void testForkTimedGetNPE()
public void testForkQuietlyJoin()
public void testForkHelpQuiesce()
public void testAbnormalInvoke()
public void testAbnormalQuietlyInvoke()
public void testAbnormalForkJoin()
public void testAbnormalForkGet()
public void testAbnormalForkTimedGet()
public void testAbnormalForkQuietlyJoin()
public void testCancelledInvoke()
public void testCancelledForkJoin()
public void testCancelledForkGet()
public void testCancelledForkTimedGet() throws Exception
Exception
public void testCancelledForkQuietlyJoin()
public void testGetPool()
public void testGetPool2()
public void testInForkJoinPool()
public void testInForkJoinPool2()
public void testSetRawResult()
public void testCompleteExceptionally2()
public void testInvokeAll2()
public void testInvokeAll1()
public void testInvokeAll3()
public void testInvokeAllCollection()
public void testInvokeAllNPE()
public void testAbnormalInvokeAll2()
public void testAbnormalInvokeAll1()
public void testAbnormalInvokeAll3()
public void testAbnormalInvokeAllCollection()
public void testTryUnfork()
public void testGetSurplusQueuedTaskCount()
public void testPeekNextLocalTask()
public void testPollNextLocalTask()
public void testPollTask()
public void testPeekNextLocalTaskAsync()
public void testPollNextLocalTaskAsync()
public void testPollTaskAsync()
public void testInvokeSingleton()
public void testQuietlyInvokeSingleton()
public void testForkJoinSingleton()
public void testForkGetSingleton()
public void testForkTimedGetSingleton()
public void testForkTimedGetNPESingleton()
public void testForkQuietlyJoinSingleton()
public void testForkHelpQuiesceSingleton()
public void testAbnormalInvokeSingleton()
public void testAbnormalQuietlyInvokeSingleton()
public void testAbnormalForkJoinSingleton()
public void testAbnormalForkGetSingleton()
public void testAbnormalForkTimedGetSingleton()
public void testAbnormalForkQuietlyJoinSingleton()
public void testCancelledInvokeSingleton()
public void testCancelledForkJoinSingleton()
public void testCancelledForkGetSingleton()
public void testCancelledForkTimedGetSingleton() throws Exception
Exception
public void testCancelledForkQuietlyJoinSingleton()
public void testCompleteExceptionallySingleton()
public void testInvokeAll2Singleton()
public void testInvokeAll1Singleton()
public void testInvokeAll3Singleton()
public void testInvokeAllCollectionSingleton()
public void testInvokeAllNPESingleton()
public void testAbnormalInvokeAll2Singleton()
public void testAbnormalInvokeAll1Singleton()
public void testAbnormalInvokeAll3Singleton()
public void testAbnormalInvokeAllCollectionSingleton()