Lines Matching refs:RecursiveTask

16 import java.util.concurrent.RecursiveTask;
48 private <T> T testInvokeOnPool(ForkJoinPool pool, RecursiveTask<T> a) { in testInvokeOnPool()
59 void checkNotDone(RecursiveTask a) { in checkNotDone()
90 <T> void checkCompletedNormally(RecursiveTask<T> a, T expected) { in checkCompletedNormally()
112 void checkCompletesNormally(RecursiveTask<Integer> a, int expected) { in checkCompletesNormally()
122 void checkCompletedNormally(RecursiveTask<Integer> a, int expected) { in checkCompletedNormally()
128 void checkCancelled(RecursiveTask a) { in checkCancelled()
155 void checkCompletedAbnormally(RecursiveTask a, Throwable t) { in checkCompletedAbnormally()
213 final class FailingFibTask extends RecursiveTask<Integer> {
234 RecursiveTask<Integer> a = new CheckedRecursiveTask<Integer>() { in testInvoke()
251 RecursiveTask<Integer> a = new CheckedRecursiveTask<Integer>() { in testQuietlyInvoke()
265 RecursiveTask<Integer> a = new CheckedRecursiveTask<Integer>() { in testForkJoin()
281 RecursiveTask<Integer> a = new CheckedRecursiveTask<Integer>() { in testForkGet()
297 RecursiveTask<Integer> a = new CheckedRecursiveTask<Integer>() { in testForkTimedGet()
313 RecursiveTask<Integer> a = new CheckedRecursiveTask<Integer>() { in testForkQuietlyJoin()
331 RecursiveTask<Integer> a = new CheckedRecursiveTask<Integer>() { in testForkHelpQuiesce()
349 RecursiveTask<Integer> a = new CheckedRecursiveTask<Integer>() { in testAbnormalInvoke()
367 RecursiveTask<Integer> a = new CheckedRecursiveTask<Integer>() { in testAbnormalQuietlyInvoke()
382 RecursiveTask<Integer> a = new CheckedRecursiveTask<Integer>() { in testAbnormalForkJoin()
401 RecursiveTask<Integer> a = new CheckedRecursiveTask<Integer>() { in testAbnormalForkGet()
422 RecursiveTask<Integer> a = new CheckedRecursiveTask<Integer>() { in testAbnormalForkTimedGet()
443 RecursiveTask<Integer> a = new CheckedRecursiveTask<Integer>() { in testAbnormalForkQuietlyJoin()
459 RecursiveTask<Integer> a = new CheckedRecursiveTask<Integer>() { in testCancelledInvoke()
478 RecursiveTask<Integer> a = new CheckedRecursiveTask<Integer>() { in testCancelledForkJoin()
498 RecursiveTask<Integer> a = new CheckedRecursiveTask<Integer>() { in testCancelledForkGet()
518 RecursiveTask<Integer> a = new CheckedRecursiveTask<Integer>() { in testCancelledForkTimedGet()
538 RecursiveTask<Integer> a = new CheckedRecursiveTask<Integer>() { in testCancelledForkQuietlyJoin()
555 RecursiveTask<Integer> a = new CheckedRecursiveTask<Integer>() { in testGetPool()
567 RecursiveTask<Integer> a = new CheckedRecursiveTask<Integer>() { in testGetPool2()
579 RecursiveTask<Integer> a = new CheckedRecursiveTask<Integer>() { in testInForkJoinPool()
591 RecursiveTask<Integer> a = new CheckedRecursiveTask<Integer>() { in testInForkJoinPool2()
603 RecursiveTask<Integer> a = new CheckedRecursiveTask<Integer>() { in testSetRawResult()
617 RecursiveTask<Integer> a = new CheckedRecursiveTask<Integer>() { in testReinitialize()
639 RecursiveTask<Integer> a = new CheckedRecursiveTask<Integer>() { in testReinitializeAbnormal()
663 RecursiveTask<Integer> a = new CheckedRecursiveTask<Integer>() { in testCompleteExceptionally()
682 RecursiveTask<Integer> a = new CheckedRecursiveTask<Integer>() { in testComplete()
698 RecursiveTask<Integer> a = new CheckedRecursiveTask<Integer>() { in testInvokeAll2()
714 RecursiveTask<Integer> a = new CheckedRecursiveTask<Integer>() { in testInvokeAll1()
728 RecursiveTask<Integer> a = new CheckedRecursiveTask<Integer>() { in testInvokeAll3()
749 RecursiveTask<Integer> a = new CheckedRecursiveTask<Integer>() { in testInvokeAllCollection()
774 RecursiveTask<Integer> a = new CheckedRecursiveTask<Integer>() { in testInvokeAllNPE()
792 RecursiveTask<Integer> a = new CheckedRecursiveTask<Integer>() { in testAbnormalInvokeAll2()
811 RecursiveTask<Integer> a = new CheckedRecursiveTask<Integer>() { in testAbnormalInvokeAll1()
829 RecursiveTask<Integer> a = new CheckedRecursiveTask<Integer>() { in testAbnormalInvokeAll3()
849 RecursiveTask<Integer> a = new CheckedRecursiveTask<Integer>() { in testAbnormalInvokeAllCollection()
874 RecursiveTask<Integer> a = new CheckedRecursiveTask<Integer>() { in testTryUnfork()
894 RecursiveTask<Integer> a = new CheckedRecursiveTask<Integer>() { in testGetSurplusQueuedTaskCount()
917 RecursiveTask<Integer> a = new CheckedRecursiveTask<Integer>() { in testPeekNextLocalTask()
937 RecursiveTask<Integer> a = new CheckedRecursiveTask<Integer>() { in testPollNextLocalTask()
956 RecursiveTask<Integer> a = new CheckedRecursiveTask<Integer>() { in testPollTask()
975 RecursiveTask<Integer> a = new CheckedRecursiveTask<Integer>() { in testPeekNextLocalTaskAsync()
996 RecursiveTask<Integer> a = new CheckedRecursiveTask<Integer>() { in testPollNextLocalTaskAsync()
1016 RecursiveTask<Integer> a = new CheckedRecursiveTask<Integer>() { in testPollTaskAsync()