Home
last modified time | relevance | path

Searched refs:CountedCompleter (Results 1 – 20 of 20) 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/luni/src/test/java/libcore/java/util/concurrent/
DCountedCompleterTest.java21 import java.util.concurrent.CountedCompleter;
43 class Task extends CountedCompleter<Integer> { in chooseOne()
64 final CountedCompleter root = getRoot(); in chooseOne()
117 class Task extends CountedCompleter<Integer> { in completeAllChildren()
120 Task(CountedCompleter<Integer> parent, int idx) { in completeAllChildren()
136 class MainTask extends CountedCompleter<Integer> { in completeAllChildren()
/libcore/ojluni/src/test/java/util/concurrent/tck/
DCountedCompleter8Test.java39 import java.util.concurrent.CountedCompleter;
60 class Task extends CountedCompleter<Void> { in forEach1()
84 class Task extends CountedCompleter<Void> { in forEach2()
108 class Task extends CountedCompleter<Void> { in forEach3()
130 class Task extends CountedCompleter<Void> { in forEach4()
DCountedCompleterTest.java40 import java.util.concurrent.CountedCompleter;
100 void checkNotDone(CountedCompleter a) { in checkNotDone()
115 void checkCompletedNormally(CountedCompleter<?> a) { in checkCompletedNormally()
149 void checkCancelled(CountedCompleter a) {
186 void checkCompletedAbnormally(CountedCompleter a, Throwable t) {
237 abstract class CheckedCC extends CountedCompleter<Object> {
249 CheckedCC(CountedCompleter p) { super(p); }
250 CheckedCC(CountedCompleter p, int n) { super(p, n); }
256 public void onCompletion(CountedCompleter caller) {
261 CountedCompleter caller) {
[all …]
DForkJoinPool8Test.java40 import java.util.concurrent.CountedCompleter;
883 abstract static class CCF extends CountedCompleter {
887 public CCF(CountedCompleter parent, int n) { in CCF()
893 CountedCompleter p; in compute()
910 public LCCF(CountedCompleter parent, int n) { in LCCF()
913 public final void onCompletion(CountedCompleter caller) { in onCompletion()
923 public RCCF(CountedCompleter parent, int n) { in RCCF()
926 public final void onCompletion(CountedCompleter caller) { in onCompletion()
937 abstract static class FailingCCF extends CountedCompleter {
941 public FailingCCF(CountedCompleter parent, int n) { in FailingCCF()
[all …]
/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/api/
Dcurrent.txt14526 public abstract class CountedCompleter<T> extends java.util.concurrent.ForkJoinTask<T> {
14527 ctor protected CountedCompleter(java.util.concurrent.CountedCompleter<?>, int);
14528 ctor protected CountedCompleter(java.util.concurrent.CountedCompleter<?>);
14529 ctor protected CountedCompleter();
14536 method public final java.util.concurrent.CountedCompleter<?> firstComplete();
14537 method public final java.util.concurrent.CountedCompleter<?> getCompleter();
14540 method public final java.util.concurrent.CountedCompleter<?> getRoot();
14542 method public final java.util.concurrent.CountedCompleter<?> nextComplete();
14543 method public void onCompletion(java.util.concurrent.CountedCompleter<?>);
14544 …method public boolean onExceptionalCompletion(Throwable, java.util.concurrent.CountedCompleter<?>);
/libcore/
Dopenjdk_java_files.bp950 "ojluni/src/main/java/java/util/concurrent/CountedCompleter.java",