Home
last modified time | relevance | path

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

/libcore/ojluni/src/main/java/java/util/concurrent/
DCountedCompleter.java412 public abstract class CountedCompleter<T> extends ForkJoinTask<T> { class
416 final CountedCompleter<?> completer;
427 protected CountedCompleter(CountedCompleter<?> completer, in CountedCompleter() method in CountedCompleter
439 protected CountedCompleter(CountedCompleter<?> completer) { in CountedCompleter() method in CountedCompleter
447 protected CountedCompleter() { in CountedCompleter() method in CountedCompleter
468 public void onCompletion(CountedCompleter<?> caller) { in onCompletion()
489 public boolean onExceptionalCompletion(Throwable ex, CountedCompleter<?> caller) { in onExceptionalCompletion()
499 public final CountedCompleter<?> getCompleter() { in getCompleter()
561 public final CountedCompleter<?> getRoot() { in getRoot()
562 CountedCompleter<?> a = this, p; in getRoot()
[all …]
DForkJoinPool.java1247 final CountedCompleter<?> popCC(CountedCompleter<?> task, int mode) { in popCC()
1254 if (o instanceof CountedCompleter) { in popCC()
1255 CountedCompleter<?> t = (CountedCompleter<?>)o; in popCC()
1256 for (CountedCompleter<?> r = t;;) { in popCC()
1297 final int pollAndExecCC(CountedCompleter<?> task) { in pollAndExecCC()
1307 else if (!(o instanceof CountedCompleter)) in pollAndExecCC()
1310 CountedCompleter<?> t = (CountedCompleter<?>)o; in pollAndExecCC()
1311 for (CountedCompleter<?> r = t;;) { in pollAndExecCC()
2035 final int helpComplete(WorkQueue w, CountedCompleter<?> task, in helpComplete()
2047 CountedCompleter<?> p; WorkQueue q; int i; in helpComplete()
[all …]
DForkJoinTask.java319 int s = ((this instanceof CountedCompleter) ? // try helping in externalAwaitDone()
321 (CountedCompleter<?>)this, 0) : in externalAwaitDone()
354 (s = ((this instanceof CountedCompleter) ? in externalInterruptibleAwaitDone()
356 (CountedCompleter<?>)this, 0) : in externalInterruptibleAwaitDone()
1029 else if ((s = ((this instanceof CountedCompleter) ? in get()
1031 (CountedCompleter<?>)this, 0) : in get()
DConcurrentHashMap.java4877 abstract static class BulkTask<K,V,R> extends CountedCompleter<R> {
5418 CountedCompleter<?> c; in compute()
5466 CountedCompleter<?> c; in compute()
5512 CountedCompleter<?> c; in compute()
5566 CountedCompleter<?> c; in compute()
5620 CountedCompleter<?> c; in compute()
5674 CountedCompleter<?> c; in compute()
5728 CountedCompleter<?> c; in compute()
5781 CountedCompleter<?> c; in compute()
5831 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.java38 import java.util.concurrent.CountedCompleter;
105 static final class CumulateTask<T> extends CountedCompleter<Void> {
257 static final class LongCumulateTask extends CountedCompleter<Void> {
407 static final class DoubleCumulateTask extends CountedCompleter<Void> {
557 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;
634 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/
Dopenjdk_java_files.bp943 "ojluni/src/main/java/java/util/concurrent/CountedCompleter.java",