Searched refs:ForkJoinTask (Results 1 – 16 of 16) sorted by relevance
/libcore/ojluni/src/main/java/java/util/concurrent/ |
D | ForkJoinPool.java | 731 private static final class EmptyTask extends ForkJoinTask<Void> { 733 EmptyTask() { status = ForkJoinTask.NORMAL; } // force done in EmptyTask() 819 ForkJoinTask<?>[] array; // the elements (initially unallocated) 823 volatile ForkJoinTask<?> currentJoin; // task being joined in awaitJoin 827 volatile ForkJoinTask<?> currentSteal; // nonnull when running some task 857 ForkJoinTask<?>[] a; int n, al, s; in isEmpty() 870 final void push(ForkJoinTask<?> task) { in push() 872 int s = top, al, d; ForkJoinTask<?>[] a; in push() 891 final ForkJoinTask<?>[] growArray() { in growArray() 892 ForkJoinTask<?>[] oldA = array; in growArray() [all …]
|
D | ForkJoinTask.java | 208 public abstract class ForkJoinTask<V> implements Future<V>, Serializable { class 436 static final class ExceptionNode extends WeakReference<ForkJoinTask<?>> { 441 ExceptionNode(ForkJoinTask<?> task, Throwable ex, ExceptionNode next, in ExceptionNode() 507 static final void cancelIgnoringExceptions(ForkJoinTask<?> t) { in cancelIgnoringExceptions() 646 ForkJoinTask.<RuntimeException>uncheckedThrow(ex); in rethrow() 689 public final ForkJoinTask<V> fork() { in fork() 748 public static void invokeAll(ForkJoinTask<?> t1, ForkJoinTask<?> t2) { in invokeAll() 772 public static void invokeAll(ForkJoinTask<?>... tasks) { in invokeAll() 776 ForkJoinTask<?> t = tasks[i]; in invokeAll() 787 ForkJoinTask<?> t = tasks[i]; in invokeAll() [all …]
|
D | RecursiveAction.java | 165 public abstract class RecursiveAction extends ForkJoinTask<Void> {
|
D | RecursiveTask.java | 68 public abstract class RecursiveTask<V> extends ForkJoinTask<V> {
|
D | CountedCompleter.java | 412 public abstract class CountedCompleter<T> extends ForkJoinTask<T> {
|
D | CompletableFuture.java | 437 abstract static class Completion extends ForkJoinTask<Void> 1610 static final class AsyncSupply<T> extends ForkJoinTask<Void> 1646 static final class AsyncRun extends ForkJoinTask<Void>
|
/libcore/jsr166-tests/src/test/java/jsr166/ |
D | CountedCompleterTest.java | 17 import java.util.concurrent.ForkJoinTask; 55 private void testInvokeOnPool(ForkJoinPool pool, ForkJoinTask a) { in testInvokeOnPool() 629 ForkJoinTask a = new CheckedRecursiveAction() { in testInvoke() 645 ForkJoinTask a = new CheckedRecursiveAction() { in testQuietlyInvoke() 659 ForkJoinTask a = new CheckedRecursiveAction() { in testForkJoin() 674 ForkJoinTask a = new CheckedRecursiveAction() { in testForkGet() 689 ForkJoinTask a = new CheckedRecursiveAction() { in testForkTimedGet() 704 ForkJoinTask a = new CheckedRecursiveAction() { in testForkTimedGetNPE() 720 ForkJoinTask a = new CheckedRecursiveAction() { in testForkQuietlyJoin() 736 ForkJoinTask a = new CheckedRecursiveAction() { in testForkHelpQuiesce() [all …]
|
D | ForkJoinPool8Test.java | 17 import java.util.concurrent.ForkJoinTask; 67 private void checkInvoke(ForkJoinTask a) { in checkInvoke() 73 void checkNotDone(ForkJoinTask a) { in checkNotDone() 81 if (! ForkJoinTask.inForkJoinPool()) { in checkNotDone() 104 void checkCompletedNormally(ForkJoinTask a) { in checkCompletedNormally() 122 void checkCancelled(ForkJoinTask a) { in checkCancelled() 149 void checkCompletedAbnormally(ForkJoinTask a, Throwable t) { in checkCompletedAbnormally() 973 ForkJoinTask a = new CheckedRecursiveAction() { in testInvokeCC() 989 ForkJoinTask a = new CheckedRecursiveAction() { in testQuietlyInvokeCC() 1003 ForkJoinTask a = new CheckedRecursiveAction() { in testForkJoinCC() [all …]
|
D | ForkJoinPoolTest.java | 23 import java.util.concurrent.ForkJoinTask; 90 public int drainTasksTo(Collection<? super ForkJoinTask<?>> c) { in drainTasksTo() 93 public ForkJoinTask<?> pollSubmission() { in pollSubmission() 127 static final class FailingTask extends ForkJoinTask<Void> { 347 ForkJoinTask<Integer> f = p.submit(new FibTask(8)); 361 ForkJoinTask<Integer> f = p.submit(new FibTask(8)); 375 ForkJoinTask<Integer> f = new LockingFibTask(20, locker, lock); 390 ForkJoinTask a = p.submit(awaiter(done)); 391 ForkJoinTask b = p.submit(awaiter(done)); 392 ForkJoinTask c = p.submit(awaiter(done)); [all …]
|
D | ForkJoinTask8Test.java | 17 import java.util.concurrent.ForkJoinTask; 100 void checkNotDone(ForkJoinTask a) { in checkNotDone() 117 <T> void checkCompletedNormally(ForkJoinTask<T> a) { in checkCompletedNormally() 121 <T> void checkCompletedNormally(ForkJoinTask<T> a, T expected) { in checkCompletedNormally() 157 void checkCompletedAbnormally(ForkJoinTask a, Throwable t) { 203 abstract static class BinaryAsyncAction extends ForkJoinTask<Void> { 927 ForkJoinTask[] tasks = { f, g }; 954 ForkJoinTask[] tasks = { f, g, h }; 981 ForkJoinTask[] tasks = { f, g, h }; 1176 final ForkJoinTask a = ForkJoinTask.adapt(awaiter(done)); [all …]
|
D | ForkJoinTaskTest.java | 19 import java.util.concurrent.ForkJoinTask; 77 void checkNotDone(ForkJoinTask a) { in checkNotDone() 92 <T> void checkCompletedNormally(ForkJoinTask<T> a) { in checkCompletedNormally() 96 <T> void checkCompletedNormally(ForkJoinTask<T> a, T expected) { in checkCompletedNormally() 130 void checkCancelled(ForkJoinTask a) { 167 void checkCompletedAbnormally(ForkJoinTask a, Throwable t) { 219 abstract static class BinaryAsyncAction extends ForkJoinTask<Void> { 903 ForkJoinTask[] tasks = { f, g }; 941 ForkJoinTask[] tasks = { f, g, h }; 962 ForkJoinTask[] tasks = { f, g, h }; [all …]
|
D | RecursiveActionTest.java | 16 import java.util.concurrent.ForkJoinTask; 70 if (! ForkJoinTask.inForkJoinPool()) { in checkNotDone() 370 assertFalse(ForkJoinTask.inForkJoinPool()); in testJoinIgnoresInterruptsOutsideForkJoinPool()
|
D | RecursiveTaskTest.java | 15 import java.util.concurrent.ForkJoinTask; 67 if (! ForkJoinTask.inForkJoinPool()) { in checkNotDone()
|
D | CompletableFutureTest.java | 34 import java.util.concurrent.ForkJoinTask; 575 assertNull(ForkJoinTask.getPool()); 649 (ForkJoinPool.commonPool() == ForkJoinTask.getPool()));
|
/libcore/ojluni/src/main/java/java/util/stream/ |
D | ForEachOps.java | 31 import java.util.concurrent.ForkJoinTask;
|
/libcore/ |
D | openjdk_java_files.bp | 954 "ojluni/src/main/java/java/util/concurrent/ForkJoinTask.java",
|