Home
last modified time | relevance | path

Searched refs:CountedCompleter (Results 1 – 15 of 15) sorted by relevance

/libcore/luni/src/main/java/java/util/concurrent/
DCountedCompleter.java383 public abstract class CountedCompleter<T> extends ForkJoinTask<T> { class
387 final CountedCompleter<?> completer;
398 protected CountedCompleter(CountedCompleter<?> completer, in CountedCompleter() method in CountedCompleter
410 protected CountedCompleter(CountedCompleter<?> completer) { in CountedCompleter() method in CountedCompleter
418 protected CountedCompleter() { in CountedCompleter() method in CountedCompleter
439 public void onCompletion(CountedCompleter<?> caller) { in onCompletion()
460 public boolean onExceptionalCompletion(Throwable ex, CountedCompleter<?> caller) { in onExceptionalCompletion()
470 public final CountedCompleter<?> getCompleter() { in getCompleter()
532 public final CountedCompleter<?> getRoot() { in getRoot()
533 CountedCompleter<?> a = this, p; in getRoot()
[all …]
DForkJoinPool.java1215 final CountedCompleter<?> popCC(CountedCompleter<?> task, int mode) { in popCC()
1222 if (o instanceof CountedCompleter) { in popCC()
1223 CountedCompleter<?> t = (CountedCompleter<?>)o; in popCC()
1224 for (CountedCompleter<?> r = t;;) { in popCC()
1265 final int pollAndExecCC(CountedCompleter<?> task) { in pollAndExecCC()
1275 else if (!(o instanceof CountedCompleter)) in pollAndExecCC()
1278 CountedCompleter<?> t = (CountedCompleter<?>)o; in pollAndExecCC()
1279 for (CountedCompleter<?> r = t;;) { in pollAndExecCC()
2003 final int helpComplete(WorkQueue w, CountedCompleter<?> task, in helpComplete()
2015 CountedCompleter<?> p; WorkQueue q; int i; in helpComplete()
[all …]
DForkJoinTask.java290 int s = ((this instanceof CountedCompleter) ? // try helping in externalAwaitDone()
292 (CountedCompleter<?>)this, 0) : in externalAwaitDone()
325 (s = ((this instanceof CountedCompleter) ? in externalInterruptibleAwaitDone()
327 (CountedCompleter<?>)this, 0) : in externalInterruptibleAwaitDone()
1000 else if ((s = ((this instanceof CountedCompleter) ? in get()
1002 (CountedCompleter<?>)this, 0) : in get()
DConcurrentHashMap.java4846 abstract static class BulkTask<K,V,R> extends CountedCompleter<R> {
5387 CountedCompleter<?> c; in compute()
5435 CountedCompleter<?> c; in compute()
5481 CountedCompleter<?> c; in compute()
5535 CountedCompleter<?> c; in compute()
5589 CountedCompleter<?> c; in compute()
5643 CountedCompleter<?> c; in compute()
5697 CountedCompleter<?> c; in compute()
5750 CountedCompleter<?> c; in compute()
5800 CountedCompleter<?> c; in compute()
[all …]
/libcore/ojluni/src/main/java/java/util/
DArraysParallelSortHelpers.java28 import java.util.concurrent.CountedCompleter;
89 static final class EmptyCompleter extends CountedCompleter<Void> {
91 EmptyCompleter(CountedCompleter<?> p) { super(p); } in EmptyCompleter()
98 static final class Relay extends CountedCompleter<Void> {
100 final CountedCompleter<?> task;
101 Relay(CountedCompleter<?> task) { in Relay()
106 public final void onCompletion(CountedCompleter<?> t) { in onCompletion()
113 static final class Sorter<T> extends CountedCompleter<Void> {
118 Sorter(CountedCompleter<?> par, T[] a, T[] w, int base, int size, in Sorter()
127 CountedCompleter<?> s = this; in compute()
[all …]
DArrayPrefixHelpers.java9 import java.util.concurrent.CountedCompleter;
76 static final class CumulateTask<T> extends CountedCompleter<Void> {
228 static final class LongCumulateTask extends CountedCompleter<Void> {
378 static final class DoubleCumulateTask extends CountedCompleter<Void> {
528 static final class IntCumulateTask extends CountedCompleter<Void> {
/libcore/ojluni/src/main/java/java/util/stream/
DAbstractTask.java28 import java.util.concurrent.CountedCompleter;
89 extends CountedCompleter<R> {
329 public void onCompletion(CountedCompleter<?> caller) { in onCompletion()
DForEachOps.java30 import java.util.concurrent.CountedCompleter;
254 static final class ForEachTask<S, T> extends CountedCompleter<Void> {
320 static final class ForEachOrderedTask<S, T> extends CountedCompleter<Void> {
487 public void onCompletion(CountedCompleter<?> caller) { in onCompletion()
DFindOps.java32 import java.util.concurrent.CountedCompleter;
302 public void onCompletion(CountedCompleter<?> caller) { in onCompletion()
DReduceOps.java33 import java.util.concurrent.CountedCompleter;
751 public void onCompletion(CountedCompleter<?> caller) {
DSliceOps.java28 import java.util.concurrent.CountedCompleter;
622 public final void onCompletion(CountedCompleter<?> caller) {
DNodes.java35 import java.util.concurrent.CountedCompleter;
1824 extends CountedCompleter<Void>
2027 extends CountedCompleter<Void> {
2187 public void onCompletion(CountedCompleter<?> caller) {
/libcore/jsr166-tests/src/test/java/jsr166/
DCountedCompleterTest.java14 import java.util.concurrent.CountedCompleter;
75 void checkNotDone(CountedCompleter a) { in checkNotDone()
90 void checkCompletedNormally(CountedCompleter<?> a) { in checkCompletedNormally()
124 void checkCancelled(CountedCompleter a) {
161 void checkCompletedAbnormally(CountedCompleter a, Throwable t) {
212 abstract class CheckedCC extends CountedCompleter<Object> {
224 CheckedCC(CountedCompleter p) { super(p); }
225 CheckedCC(CountedCompleter p, int n) { super(p, n); }
231 public void onCompletion(CountedCompleter caller) {
236 CountedCompleter caller) {
[all …]
DForkJoinPool8Test.java14 import java.util.concurrent.CountedCompleter;
865 abstract static class CCF extends CountedCompleter {
869 public CCF(CountedCompleter parent, int n) { in CCF()
875 CountedCompleter p; in compute()
892 public LCCF(CountedCompleter parent, int n) { in LCCF()
895 public final void onCompletion(CountedCompleter caller) { in onCompletion()
905 public RCCF(CountedCompleter parent, int n) { in RCCF()
908 public final void onCompletion(CountedCompleter caller) { in onCompletion()
919 abstract static class FailingCCF extends CountedCompleter {
923 public FailingCCF(CountedCompleter parent, int n) { in FailingCCF()
[all …]
/libcore/
Dnon_openjdk_java_files.mk106 luni/src/main/java/java/util/concurrent/CountedCompleter.java \