| /libcore/jsr166-tests/src/test/java/jsr166/ |
| D | ForkJoinTaskTest.java | 251 y.fork();
252 x.fork();
352 r.fork();
377 r.fork();
427 assertSame(f, f.fork());
442 assertSame(f, f.fork());
457 assertSame(f, f.fork());
472 assertSame(f, f.fork());
488 assertSame(f, f.fork());
504 assertSame(f, f.fork());
[all …]
|
| D | RecursiveActionTest.java | 250 assertSame(f, f.fork()); in testForkJoin()
268 assertSame(f, f.fork()); in testJoinIgnoresInterrupts()
278 assertSame(f, f.fork()); in testJoinIgnoresInterrupts()
291 assertSame(f, f.fork()); in testJoinIgnoresInterrupts()
304 assertSame(f, f.fork()); in testJoinIgnoresInterrupts()
314 assertSame(f, f.fork()); in testJoinIgnoresInterrupts()
323 assertSame(f, f.fork()); in testJoinIgnoresInterrupts()
354 fibActions[i].fork(); in testJoinIgnoresInterruptsOutsideForkJoinPool()
445 assertSame(f, f.fork()); in testForkGet()
460 assertSame(f, f.fork()); in testForkTimedGet()
[all …]
|
| D | RecursiveTaskTest.java | 203 f1.fork(); in realCompute()
222 f1.fork(); in compute()
268 assertSame(f, f.fork()); in testForkJoin()
284 assertSame(f, f.fork()); in testForkGet()
300 assertSame(f, f.fork()); in testForkTimedGet()
316 assertSame(f, f.fork()); in testForkQuietlyJoin()
334 assertSame(f, f.fork()); in testForkHelpQuiesce()
385 assertSame(f, f.fork()); in testAbnormalForkJoin()
404 assertSame(f, f.fork()); in testAbnormalForkGet()
425 assertSame(f, f.fork()); in testAbnormalForkTimedGet()
[all …]
|
| D | ForkJoinTask8Test.java | 236 y.fork();
237 x.fork();
322 r.fork();
360 r.fork();
432 assertSame(f, f.fork());
452 assertSame(f, f.fork());
472 assertSame(f, f.fork());
492 assertSame(f, f.fork());
514 assertSame(f, f.fork());
535 assertSame(f, f.fork());
[all …]
|
| D | CountedCompleterTest.java | 540 new RCCF(f, n - 2).fork();
591 new RFCCF(f, n - 2).fork();
662 assertSame(f, f.fork()); in testForkJoin()
677 assertSame(f, f.fork()); in testForkGet()
692 assertSame(f, f.fork()); in testForkTimedGet()
707 assertSame(f, f.fork()); in testForkTimedGetNPE()
723 assertSame(f, f.fork()); in testForkQuietlyJoin()
739 assertSame(f, f.fork()); in testForkHelpQuiesce()
786 assertSame(f, f.fork()); in testAbnormalForkJoin()
804 assertSame(f, f.fork()); in testAbnormalForkGet()
[all …]
|
| D | ForkJoinPool8Test.java | 261 assertSame(f, f.fork()); in testForkJoin()
279 assertSame(f, f.fork()); in testJoinIgnoresInterrupts()
289 assertSame(f, f.fork()); in testJoinIgnoresInterrupts()
302 assertSame(f, f.fork()); in testJoinIgnoresInterrupts()
315 assertSame(f, f.fork()); in testJoinIgnoresInterrupts()
325 assertSame(f, f.fork()); in testJoinIgnoresInterrupts()
334 assertSame(f, f.fork()); in testJoinIgnoresInterrupts()
353 assertSame(f, f.fork()); in testForkGet()
368 assertSame(f, f.fork()); in testForkTimedGet()
383 assertSame(f, f.fork()); in testForkTimedGetNPE()
[all …]
|
| D | ForkJoinPoolTest.java | 121 f1.fork(); in compute()
158 f1.fork(); in compute()
|
| /libcore/ojluni/src/test/java/util/concurrent/tck/ |
| D | ForkJoinTaskTest.java | 273 y.fork();
274 x.fork();
374 r.fork();
399 r.fork();
449 assertSame(f, f.fork());
464 assertSame(f, f.fork());
479 assertSame(f, f.fork());
494 assertSame(f, f.fork());
510 assertSame(f, f.fork());
526 assertSame(f, f.fork());
[all …]
|
| D | RecursiveActionTest.java | 274 assertSame(f, f.fork()); in testForkJoin()
292 assertSame(f, f.fork()); in testJoinIgnoresInterrupts()
301 assertSame(f, f.fork()); in testJoinIgnoresInterrupts()
313 assertSame(f, f.fork()); in testJoinIgnoresInterrupts()
325 assertSame(f, f.fork()); in testJoinIgnoresInterrupts()
334 assertSame(f, f.fork()); in testJoinIgnoresInterrupts()
342 assertSame(f, f.fork()); in testJoinIgnoresInterrupts()
372 fibActions[i].fork(); in testJoinIgnoresInterruptsOutsideForkJoinPool()
457 assertSame(f, f.fork()); in testForkGet()
472 assertSame(f, f.fork()); in testForkTimedGet()
[all …]
|
| D | RecursiveTaskTest.java | 226 f1.fork(); in realCompute()
245 f1.fork(); in compute()
291 assertSame(f, f.fork()); in testForkJoin()
307 assertSame(f, f.fork()); in testForkGet()
323 assertSame(f, f.fork()); in testForkTimedGet()
339 assertSame(f, f.fork()); in testForkQuietlyJoin()
357 assertSame(f, f.fork()); in testForkHelpQuiesce()
408 assertSame(f, f.fork()); in testAbnormalForkJoin()
427 assertSame(f, f.fork()); in testAbnormalForkGet()
448 assertSame(f, f.fork()); in testAbnormalForkTimedGet()
[all …]
|
| D | ForkJoinTask8Test.java | 259 y.fork();
260 x.fork();
345 r.fork();
383 r.fork();
455 assertSame(f, f.fork());
475 assertSame(f, f.fork());
495 assertSame(f, f.fork());
515 assertSame(f, f.fork());
537 assertSame(f, f.fork());
558 assertSame(f, f.fork());
[all …]
|
| D | CountedCompleterTest.java | 565 new RCCF(f, n - 2).fork();
616 new RFCCF(f, n - 2).fork();
687 assertSame(f, f.fork()); in testForkJoin()
702 assertSame(f, f.fork()); in testForkGet()
717 assertSame(f, f.fork()); in testForkTimedGet()
732 assertSame(f, f.fork()); in testForkTimedGetNPE()
748 assertSame(f, f.fork()); in testForkQuietlyJoin()
764 assertSame(f, f.fork()); in testForkHelpQuiesce()
811 assertSame(f, f.fork()); in testAbnormalForkJoin()
829 assertSame(f, f.fork()); in testAbnormalForkGet()
[all …]
|
| D | ForkJoinPool8Test.java | 285 assertSame(f, f.fork()); in testForkJoin()
303 assertSame(f, f.fork()); in testJoinIgnoresInterrupts()
312 assertSame(f, f.fork()); in testJoinIgnoresInterrupts()
324 assertSame(f, f.fork()); in testJoinIgnoresInterrupts()
336 assertSame(f, f.fork()); in testJoinIgnoresInterrupts()
345 assertSame(f, f.fork()); in testJoinIgnoresInterrupts()
353 assertSame(f, f.fork()); in testJoinIgnoresInterrupts()
371 assertSame(f, f.fork()); in testForkGet()
386 assertSame(f, f.fork()); in testForkTimedGet()
401 assertSame(f, f.fork()); in testForkTimedGetNPE()
[all …]
|
| D | CountedCompleter8Test.java | 71 new Task(this, mid, hi).fork(); // right child in forEach1()
72 new Task(this, lo, mid).fork(); // left child in forEach1()
94 new Task(this, mid, hi).fork(); // right child in forEach2()
118 new Task(this, lo + n/2, lo + n).fork(); in forEach3()
139 new Task(this, lo + n/2, lo + n).fork(); in forEach4()
|
| D | ForkJoinPoolTest.java | 139 f1.fork(); in compute()
176 f1.fork(); in compute()
|
| /libcore/ojluni/src/test/java/lang/ref/ |
| D | BasicTest.java | 58 static void fork(Runnable proc) throws InterruptedException { in fork() method in BasicTest
65 fork(new Runnable() { in showReferences()
76 fork(new Runnable() { in createNoise()
86 fork(new Runnable() { in test()
120 fork(new Runnable() { in test()
|
| /libcore/ojluni/src/main/java/java/util/ |
| D | ArraysParallelSortHelpers.java | 137 new Sorter<>(rc, a, w, b+u, n-u, wb+u, g, c).fork(); in compute()
138 new Sorter<>(rc, a, w, b+h, q, wb+h, g, c).fork();; in compute()
141 new Sorter<>(bc, a, w, b+q, h-q, wb+q, g, c).fork(); in compute()
208 m.fork(); in compute()
255 new Sorter(rc, a, w, b+u, n-u, wb+u, g).fork(); in compute()
256 new Sorter(rc, a, w, b+h, q, wb+h, g).fork();; in compute()
259 new Sorter(bc, a, w, b+q, h-q, wb+q, g).fork(); in compute()
321 m.fork(); in compute()
366 new Sorter(rc, a, w, b+u, n-u, wb+u, g).fork(); in compute()
367 new Sorter(rc, a, w, b+h, q, wb+h, g).fork();; in compute()
[all …]
|
| D | ArrayPrefixHelpers.java | 184 f.fork(); in compute()
245 par.fork(); in compute()
336 f.fork(); in compute()
395 par.fork(); in compute()
486 f.fork(); in compute()
545 par.fork(); in compute()
636 f.fork(); in compute()
695 par.fork(); in compute()
|
| /libcore/luni/src/test/java/libcore/java/util/concurrent/ |
| D | RecursiveTaskTest.java | 46 subTask.fork(); in compute()
65 task.fork(); in testSetRawResult()
|
| D | CountedCompleterTest.java | 60 new Task(this, mid, hi).fork(); // right child in chooseOne()
61 new Task(this, lo, mid).fork(); // left child in chooseOne()
|
| /libcore/ojluni/src/main/java/java/util/concurrent/ |
| D | ForkJoinTask.java | 703 public final ForkJoinTask<V> fork() { in fork() method in ForkJoinTask
764 t2.fork(); in invokeAll()
796 t.fork(); in invokeAll()
848 t.fork(); in invokeAll()
|
| D | ConcurrentHashMap.java | 4994 action).fork(); in compute()
5021 action).fork(); in compute()
5048 action).fork(); in compute()
5075 action).fork(); in compute()
5105 transformer, action).fork(); in compute()
5138 transformer, action).fork(); in compute()
5171 transformer, action).fork(); in compute()
5205 transformer, action).fork(); in compute()
5242 searchFunction, result).fork(); in compute()
5286 searchFunction, result).fork(); in compute()
[all …]
|
| /libcore/ojluni/src/main/java/java/util/stream/ |
| D | AbstractTask.java | 313 taskToFork.fork(); in compute()
|
| D | AbstractShortCircuitTask.java | 133 taskToFork.fork(); in compute()
|
| D | ForEachOps.java | 307 taskToFork.fork(); in compute()
461 taskToFork.fork(); in doCompute()
|