/libcore/luni/src/main/java/java/util/concurrent/ |
D | CountedCompleter.java | 383 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 …]
|
D | ForkJoinPool.java | 1215 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 …]
|
D | ForkJoinTask.java | 290 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()
|
D | ConcurrentHashMap.java | 4846 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/ |
D | ArraysParallelSortHelpers.java | 28 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 …]
|
D | ArrayPrefixHelpers.java | 9 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/ |
D | AbstractTask.java | 28 import java.util.concurrent.CountedCompleter; 89 extends CountedCompleter<R> { 329 public void onCompletion(CountedCompleter<?> caller) { in onCompletion()
|
D | ForEachOps.java | 30 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()
|
D | FindOps.java | 32 import java.util.concurrent.CountedCompleter; 302 public void onCompletion(CountedCompleter<?> caller) { in onCompletion()
|
D | ReduceOps.java | 33 import java.util.concurrent.CountedCompleter; 751 public void onCompletion(CountedCompleter<?> caller) {
|
D | SliceOps.java | 28 import java.util.concurrent.CountedCompleter; 622 public final void onCompletion(CountedCompleter<?> caller) {
|
D | Nodes.java | 35 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/ |
D | CountedCompleterTest.java | 14 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 …]
|
D | ForkJoinPool8Test.java | 14 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/ |
D | non_openjdk_java_files.mk | 106 luni/src/main/java/java/util/concurrent/CountedCompleter.java \
|