Searched refs:ForkJoinTask (Results 1 - 16 of 16) sorted by relevance
/libcore/luni/src/main/java/java/util/concurrent/ |
H A D | RecursiveAction.java | 10 * 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 D | RecursiveTask.java | 10 * A recursive result-bearing {@link ForkJoinTask}. 39 public abstract class RecursiveTask<V> extends ForkJoinTask<V> {
|
H A D | ForkJoinPool.java | 22 * 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 D | ForkJoinTask.java | 24 * 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 D | CountedCompleter.java | 10 * 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 D | CompletableFuture.java | 116 * 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 D | CountedCompleterTest.java | 17 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 D | ForkJoinPool8Test.java | 17 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 D | ForkJoinTask8Test.java | 17 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 D | ForkJoinPoolTest.java | 23 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 D | ForkJoinTaskTest.java | 19 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 D | RecursiveActionTest.java | 16 import java.util.concurrent.ForkJoinTask; 70 if (! ForkJoinTask.inForkJoinPool()) { 370 assertFalse(ForkJoinTask.inForkJoinPool());
|
H A D | RecursiveTaskTest.java | 15 import java.util.concurrent.ForkJoinTask; 67 if (! ForkJoinTask.inForkJoinPool()) {
|
H A 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/ |
H A D | ForEachOps.java | 31 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 D | non_openjdk_java_files.mk | 117 luni/src/main/java/java/util/concurrent/ForkJoinTask.java \
|
Completed in 172 milliseconds