Home
last modified time | relevance | path

Searched refs:ForkJoinTask (Results 1 – 25 of 27) sorted by relevance

12

/libcore/ojluni/src/main/java/java/util/concurrent/
DForkJoinPool.java731 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 …]
DForkJoinTask.java208 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 …]
DRecursiveAction.java165 public abstract class RecursiveAction extends ForkJoinTask<Void> {
DRecursiveTask.java68 public abstract class RecursiveTask<V> extends ForkJoinTask<V> {
DCountedCompleter.java412 public abstract class CountedCompleter<T> extends ForkJoinTask<T> {
DCompletableFuture.java437 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/
DCountedCompleterTest.java17 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 …]
DForkJoinPool8Test.java17 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 …]
DForkJoinPoolTest.java23 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 …]
DForkJoinTask8Test.java17 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 …]
DForkJoinTaskTest.java19 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 …]
DRecursiveActionTest.java16 import java.util.concurrent.ForkJoinTask;
70 if (! ForkJoinTask.inForkJoinPool()) { in checkNotDone()
370 assertFalse(ForkJoinTask.inForkJoinPool()); in testJoinIgnoresInterruptsOutsideForkJoinPool()
DRecursiveTaskTest.java15 import java.util.concurrent.ForkJoinTask;
67 if (! ForkJoinTask.inForkJoinPool()) { in checkNotDone()
DCompletableFutureTest.java34 import java.util.concurrent.ForkJoinTask;
575 assertNull(ForkJoinTask.getPool());
649 (ForkJoinPool.commonPool() == ForkJoinTask.getPool()));
/libcore/ojluni/src/test/java/util/concurrent/tck/
DCountedCompleterTest.java43 import java.util.concurrent.ForkJoinTask;
80 private void testInvokeOnPool(ForkJoinPool pool, ForkJoinTask a) { in testInvokeOnPool()
654 ForkJoinTask a = new CheckedRecursiveAction() { in testInvoke()
670 ForkJoinTask a = new CheckedRecursiveAction() { in testQuietlyInvoke()
684 ForkJoinTask a = new CheckedRecursiveAction() { in testForkJoin()
699 ForkJoinTask a = new CheckedRecursiveAction() { in testForkGet()
714 ForkJoinTask a = new CheckedRecursiveAction() { in testForkTimedGet()
729 ForkJoinTask a = new CheckedRecursiveAction() { in testForkTimedGetNPE()
745 ForkJoinTask a = new CheckedRecursiveAction() { in testForkQuietlyJoin()
761 ForkJoinTask a = new CheckedRecursiveAction() { in testForkHelpQuiesce()
[all …]
DForkJoinPool8Test.java43 import java.util.concurrent.ForkJoinTask;
91 private void checkInvoke(ForkJoinTask a) { in checkInvoke()
97 void checkNotDone(ForkJoinTask a) { in checkNotDone()
105 if (! ForkJoinTask.inForkJoinPool()) { in checkNotDone()
128 void checkCompletedNormally(ForkJoinTask a) { in checkCompletedNormally()
146 void checkCancelled(ForkJoinTask a) { in checkCancelled()
173 void checkCompletedAbnormally(ForkJoinTask a, Throwable t) { in checkCompletedAbnormally()
991 ForkJoinTask a = new CheckedRecursiveAction() { in testInvokeCC()
1007 ForkJoinTask a = new CheckedRecursiveAction() { in testQuietlyInvokeCC()
1021 ForkJoinTask a = new CheckedRecursiveAction() { in testForkJoinCC()
[all …]
DForkJoinPoolTest.java49 import java.util.concurrent.ForkJoinTask;
108 public int drainTasksTo(Collection<? super ForkJoinTask<?>> c) { in drainTasksTo()
111 public ForkJoinTask<?> pollSubmission() { in pollSubmission()
145 static final class FailingTask extends ForkJoinTask<Void> {
365 ForkJoinTask<Integer> f = p.submit(new FibTask(8));
379 ForkJoinTask<Integer> f = p.submit(new FibTask(8));
393 ForkJoinTask<Integer> f = new LockingFibTask(20, locker, lock);
408 ForkJoinTask a = p.submit(awaiter(done));
409 ForkJoinTask b = p.submit(awaiter(done));
410 ForkJoinTask c = p.submit(awaiter(done));
[all …]
DForkJoinTask8Test.java42 import java.util.concurrent.ForkJoinTask;
123 void checkNotDone(ForkJoinTask a) { in checkNotDone()
140 <T> void checkCompletedNormally(ForkJoinTask<T> a) { in checkCompletedNormally()
144 <T> void checkCompletedNormally(ForkJoinTask<T> a, T expected) { in checkCompletedNormally()
180 void checkCompletedAbnormally(ForkJoinTask a, Throwable t) {
226 abstract static class BinaryAsyncAction extends ForkJoinTask<Void> {
950 ForkJoinTask[] tasks = { f, g };
977 ForkJoinTask[] tasks = { f, g, h };
1004 ForkJoinTask[] tasks = { f, g, h };
1199 final ForkJoinTask a = ForkJoinTask.adapt(awaiter(done));
[all …]
DForkJoinTaskTest.java43 import java.util.concurrent.ForkJoinTask;
99 void checkNotDone(ForkJoinTask a) { in checkNotDone()
114 <T> void checkCompletedNormally(ForkJoinTask<T> a) { in checkCompletedNormally()
118 <T> void checkCompletedNormally(ForkJoinTask<T> a, T expected) { in checkCompletedNormally()
152 void checkCancelled(ForkJoinTask a) {
189 void checkCompletedAbnormally(ForkJoinTask a, Throwable t) {
241 abstract static class BinaryAsyncAction extends ForkJoinTask<Void> {
925 ForkJoinTask[] tasks = { f, g };
963 ForkJoinTask[] tasks = { f, g, h };
984 ForkJoinTask[] tasks = { f, g, h };
[all …]
DRecursiveActionTest.java42 import java.util.concurrent.ForkJoinTask;
94 if (! ForkJoinTask.inForkJoinPool()) { in checkNotDone()
388 assertFalse(ForkJoinTask.inForkJoinPool()); in testJoinIgnoresInterruptsOutsideForkJoinPool()
DRecursiveTaskTest.java41 import java.util.concurrent.ForkJoinTask;
90 if (! ForkJoinTask.inForkJoinPool()) { in checkNotDone()
DCompletableFutureTest.java60 import java.util.concurrent.ForkJoinTask;
614 assertNull(ForkJoinTask.getPool());
688 (ForkJoinPool.commonPool() == ForkJoinTask.getPool()));
/libcore/luni/src/test/java/libcore/java/util/concurrent/
DForkJoinTaskTest.java26 import java.util.concurrent.ForkJoinTask;
42 final ForkJoinTask task = ForkJoinTask.adapt(() -> result.addAndGet(42), result); in testAdaptToRunnableWithResult()
61 final ForkJoinTask task = ForkJoinTask.adapt(callable); in testAdaptToCallable()
80 final ForkJoinTask task = ForkJoinTask.adapt(callable); in testAdaptToCallableThrowsException()
DForkJoinPoolTest.java24 import java.util.concurrent.ForkJoinTask;
40 ForkJoinTask task = pool.submit(() -> result.addAndGet(42), result); in testSubmit()
56 ForkJoinTask task = pool.submit(new Runnable() { in testGetRunningThreadCount()
/libcore/ojluni/src/main/java/java/util/stream/
DForEachOps.java31 import java.util.concurrent.ForkJoinTask;

12