Searched refs:ForkJoinTask (Results 1 - 16 of 16) sorted by relevance

/libcore/luni/src/main/java/java/util/concurrent/
H A DRecursiveAction.java10 * A recursive resultless {@link ForkJoinTask}. This class
12 * {@code Void} {@code ForkJoinTask}s. Because {@code null} is the
136 public abstract class RecursiveAction extends ForkJoinTask<Void> {
H A DRecursiveTask.java10 * A recursive result-bearing {@link ForkJoinTask}.
39 public abstract class RecursiveTask<V> extends ForkJoinTask<V> {
H A DForkJoinPool.java22 * An {@link ExecutorService} for running {@link ForkJoinTask}s.
24 * from non-{@code ForkJoinTask} clients, as well as management and
33 * (as do most {@code ForkJoinTask}s), as well as when many small
40 * most applications. The common pool is used by any ForkJoinTask that
68 * forms of these methods accept instances of {@code ForkJoinTask},
85 * <td> {@link #execute(ForkJoinTask)}</td>
86 * <td> {@link ForkJoinTask#fork}</td>
90 * <td> {@link #invoke(ForkJoinTask)}</td>
91 * <td> {@link ForkJoinTask#invoke}</td>
95 * <td> {@link #submit(ForkJoinTask)}</t
[all...]
H A DForkJoinTask.java24 * A {@code ForkJoinTask} is a thread-like entity that is much
29 * <p>A "main" {@code ForkJoinTask} begins execution when it is
35 * using {@code ForkJoinTask} employ only methods {@link #fork} and
37 * #invokeAll(ForkJoinTask...) invokeAll}. However, this class also
42 * <p>A {@code ForkJoinTask} is a lightweight form of {@link Future}.
43 * The efficiency of {@code ForkJoinTask}s stems from a set of
116 * <p>The ForkJoinTask class is not usually directly subclassed.
122 * other actions. Normally, a concrete ForkJoinTask subclass declares
136 * ForkJoinTask may be atomically <em>tagged</em> with a {@code short}
139 * #getForkJoinTaskTag}. The ForkJoinTask implementatio
179 public abstract class ForkJoinTask<V> implements Future<V>, Serializable { class in inherits:Future,Serializable
[all...]
H A DCountedCompleter.java10 * A {@link ForkJoinTask} with a completion action performed when
63 * used as a regular ForkJoinTask with this added functionality.
66 * status (as reported in methods such as {@link ForkJoinTask#isDone})
68 * {@link #complete}, {@link ForkJoinTask#cancel},
69 * {@link ForkJoinTask#completeExceptionally(Throwable)} or upon
383 public abstract class CountedCompleter<T> extends ForkJoinTask<T> {
447 * {@link ForkJoinTask#isCompletedAbnormally}. The return value
630 * ForkJoinTask#quietlyComplete} and returns {@code null}. Or, if
689 * Supports ForkJoinTask exception propagation.
H A DCompletableFuture.java116 * Completion extends ForkJoinTask to enable async execution
406 abstract static class Completion extends ForkJoinTask<Void>
1579 static final class AsyncSupply<T> extends ForkJoinTask<Void>
1615 static final class AsyncRun extends ForkJoinTask<Void>
/libcore/jsr166-tests/src/test/java/jsr166/
H A DCountedCompleterTest.java17 import java.util.concurrent.ForkJoinTask;
55 private void testInvokeOnPool(ForkJoinPool pool, ForkJoinTask a) {
629 ForkJoinTask a = new CheckedRecursiveAction() {
645 ForkJoinTask a = new CheckedRecursiveAction() {
659 ForkJoinTask a = new CheckedRecursiveAction() {
674 ForkJoinTask a = new CheckedRecursiveAction() {
689 ForkJoinTask a = new CheckedRecursiveAction() {
704 ForkJoinTask a = new CheckedRecursiveAction() {
720 ForkJoinTask a = new CheckedRecursiveAction() {
736 ForkJoinTask
[all...]
H A DForkJoinPool8Test.java17 import java.util.concurrent.ForkJoinTask;
67 private void checkInvoke(ForkJoinTask a) {
73 void checkNotDone(ForkJoinTask a) {
81 if (! ForkJoinTask.inForkJoinPool()) {
104 void checkCompletedNormally(ForkJoinTask a) {
122 void checkCancelled(ForkJoinTask a) {
149 void checkCompletedAbnormally(ForkJoinTask a, Throwable t) {
973 ForkJoinTask a = new CheckedRecursiveAction() {
989 ForkJoinTask a = new CheckedRecursiveAction() {
1003 ForkJoinTask
[all...]
H A DForkJoinTask8Test.java17 import java.util.concurrent.ForkJoinTask;
100 void checkNotDone(ForkJoinTask a) {
117 <T> void checkCompletedNormally(ForkJoinTask<T> a) {
121 <T> void checkCompletedNormally(ForkJoinTask<T> a, T expected) {
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 };
1149 * ForkJoinTask
[all...]
H A DForkJoinPoolTest.java23 import java.util.concurrent.ForkJoinTask;
90 public int drainTasksTo(Collection<? super ForkJoinTask<?>> c) {
93 public ForkJoinTask<?> pollSubmission() {
127 static final class FailingTask extends ForkJoinTask<Void> {
342 * Completed submit(ForkJoinTask) returns result
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
[all...]
H A DForkJoinTaskTest.java19 import java.util.concurrent.ForkJoinTask;
77 void checkNotDone(ForkJoinTask a) {
92 <T> void checkCompletedNormally(ForkJoinTask<T> a) {
96 <T> void checkCompletedNormally(ForkJoinTask<T> a, T expected) {
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[] task
[all...]
H A DRecursiveActionTest.java16 import java.util.concurrent.ForkJoinTask;
70 if (! ForkJoinTask.inForkJoinPool()) {
370 assertFalse(ForkJoinTask.inForkJoinPool());
H A DRecursiveTaskTest.java15 import java.util.concurrent.ForkJoinTask;
67 if (! ForkJoinTask.inForkJoinPool()) {
H A DCompletableFutureTest.java34 import java.util.concurrent.ForkJoinTask;
575 assertNull(ForkJoinTask.getPool());
649 (ForkJoinPool.commonPool() == ForkJoinTask.getPool()));
/libcore/ojluni/src/main/java/java/util/stream/
H A DForEachOps.java31 import java.util.concurrent.ForkJoinTask;
252 /** A {@code ForkJoinTask} for performing a parallel for-each operation */
316 * A {@code ForkJoinTask} for performing a parallel for-each operation
/libcore/
H A Dnon_openjdk_java_files.mk117 luni/src/main/java/java/util/concurrent/ForkJoinTask.java \

Completed in 172 milliseconds