Home
last modified time | relevance | path

Searched refs:ForkJoinPool (Results 1 – 23 of 23) sorted by relevance

/libcore/jsr166-tests/src/test/java/jsr166/
DForkJoinPoolTest.java22 import java.util.concurrent.ForkJoinPool;
75 public FailingFJWSubclass(ForkJoinPool p) { super(p) ; } in FailingFJWSubclass()
80 implements ForkJoinPool.ForkJoinWorkerThreadFactory {
82 public ForkJoinWorkerThread newThread(ForkJoinPool p) { in newThread()
88 static class SubFJP extends ForkJoinPool { // to expose protected
98 static class ManagedLocker implements ForkJoinPool.ManagedBlocker {
170 ForkJoinPool p = new ForkJoinPool(1); in testDefaultInitialState()
172 assertSame(ForkJoinPool.defaultForkJoinWorkerThreadFactory, in testDefaultInitialState()
191 new ForkJoinPool(-1); in testConstructor1()
201 new ForkJoinPool(1, null, null, false); in testConstructor2()
[all …]
DForkJoinTask8Test.java16 import java.util.concurrent.ForkJoinPool;
55 private static ForkJoinPool mainPool() { in mainPool()
56 return new ForkJoinPool(mainPoolSize); in mainPool()
59 private static ForkJoinPool singletonPool() { in singletonPool()
60 return new ForkJoinPool(1); in singletonPool()
63 private static ForkJoinPool asyncSingletonPool() { in asyncSingletonPool()
64 return new ForkJoinPool(1, in asyncSingletonPool()
65 ForkJoinPool.defaultForkJoinWorkerThreadFactory, in asyncSingletonPool()
80 private void testInvokeOnPool(ForkJoinPool pool, RecursiveAction a) { in testInvokeOnPool()
388 public void testInvoke(ForkJoinPool pool) {
[all …]
DForkJoinPool8Test.java16 import java.util.concurrent.ForkJoinPool;
39 assertEquals(ForkJoinPool.getCommonPoolParallelism(), in testCommonPoolParallelism()
40 ForkJoinPool.commonPool().getParallelism()); in testCommonPoolParallelism()
47 assertFalse(ForkJoinPool.commonPool().isShutdown()); in testCommonPoolShutDown()
48 assertFalse(ForkJoinPool.commonPool().isTerminating()); in testCommonPoolShutDown()
49 assertFalse(ForkJoinPool.commonPool().isTerminated()); in testCommonPoolShutDown()
50 ForkJoinPool.commonPool().shutdown(); in testCommonPoolShutDown()
51 assertFalse(ForkJoinPool.commonPool().isShutdown()); in testCommonPoolShutDown()
52 assertFalse(ForkJoinPool.commonPool().isTerminating()); in testCommonPoolShutDown()
53 assertFalse(ForkJoinPool.commonPool().isTerminated()); in testCommonPoolShutDown()
[all …]
DRecursiveActionTest.java15 import java.util.concurrent.ForkJoinPool;
38 private static ForkJoinPool mainPool() { in mainPool()
39 return new ForkJoinPool(); in mainPool()
42 private static ForkJoinPool singletonPool() { in singletonPool()
43 return new ForkJoinPool(1); in singletonPool()
46 private static ForkJoinPool asyncSingletonPool() { in asyncSingletonPool()
47 return new ForkJoinPool(1, in asyncSingletonPool()
48 ForkJoinPool.defaultForkJoinWorkerThreadFactory, in asyncSingletonPool()
52 private void testInvokeOnPool(ForkJoinPool pool, RecursiveAction a) { in testInvokeOnPool()
716 final ForkJoinPool mainPool = mainPool(); in testGetPool()
[all …]
DRecursiveTaskTest.java14 import java.util.concurrent.ForkJoinPool;
34 private static ForkJoinPool mainPool() { in mainPool()
35 return new ForkJoinPool(); in mainPool()
38 private static ForkJoinPool singletonPool() { in singletonPool()
39 return new ForkJoinPool(1); in singletonPool()
42 private static ForkJoinPool asyncSingletonPool() { in asyncSingletonPool()
43 return new ForkJoinPool(1, in asyncSingletonPool()
44 ForkJoinPool.defaultForkJoinWorkerThreadFactory, in asyncSingletonPool()
48 private <T> T testInvokeOnPool(ForkJoinPool pool, RecursiveTask<T> a) { in testInvokeOnPool()
554 final ForkJoinPool mainPool = mainPool(); in testGetPool()
DForkJoinTaskTest.java18 import java.util.concurrent.ForkJoinPool;
43 private static ForkJoinPool mainPool() { in mainPool()
44 return new ForkJoinPool(mainPoolSize); in mainPool()
47 private static ForkJoinPool singletonPool() { in singletonPool()
48 return new ForkJoinPool(1); in singletonPool()
51 private static ForkJoinPool asyncSingletonPool() { in asyncSingletonPool()
52 return new ForkJoinPool(1, in asyncSingletonPool()
53 ForkJoinPool.defaultForkJoinWorkerThreadFactory, in asyncSingletonPool()
57 private void testInvokeOnPool(ForkJoinPool pool, RecursiveAction a) { in testInvokeOnPool()
711 final ForkJoinPool mainPool = mainPool();
DCountedCompleterTest.java16 import java.util.concurrent.ForkJoinPool;
41 private static ForkJoinPool mainPool() { in mainPool()
42 return new ForkJoinPool(mainPoolSize); in mainPool()
45 private static ForkJoinPool singletonPool() { in singletonPool()
46 return new ForkJoinPool(1); in singletonPool()
49 private static ForkJoinPool asyncSingletonPool() { in asyncSingletonPool()
50 return new ForkJoinPool(1, in asyncSingletonPool()
51 ForkJoinPool.defaultForkJoinWorkerThreadFactory, in asyncSingletonPool()
55 private void testInvokeOnPool(ForkJoinPool pool, ForkJoinTask a) { in testInvokeOnPool()
946 final ForkJoinPool mainPool = mainPool(); in testGetPool()
DJSR166TestCase.java45 import java.util.concurrent.ForkJoinPool;
693 if (!ForkJoinPool.commonPool() in checkForkJoinPoolThreadLeaks()
DCompletableFutureTest.java33 import java.util.concurrent.ForkJoinPool;
565 = ForkJoinPool.getCommonPoolParallelism() > 1;
649 (ForkJoinPool.commonPool() == ForkJoinTask.getPool()));
3364 Executor c = ForkJoinPool.commonPool(); in testDefaultExecutor()
3365 if (ForkJoinPool.getCommonPoolParallelism() > 1) in testDefaultExecutor()
/libcore/ojluni/src/main/java/java/util/concurrent/
DForkJoinWorkerThread.java73 final ForkJoinPool pool; // the pool this thread works in
74 final ForkJoinPool.WorkQueue workQueue; // work-stealing mechanics
82 protected ForkJoinWorkerThread(ForkJoinPool pool) { in ForkJoinWorkerThread()
92 ForkJoinWorkerThread(ForkJoinPool pool, ThreadGroup threadGroup, in ForkJoinWorkerThread()
106 public ForkJoinPool getPool() { in getPool()
222 InnocuousForkJoinWorkerThread(ForkJoinPool pool) { in InnocuousForkJoinWorkerThread()
DForkJoinTask.java320 ForkJoinPool.common.externalHelpComplete( in externalAwaitDone()
322 ForkJoinPool.common.tryExternalUnpush(this) ? doExec() : 0); in externalAwaitDone()
355 ForkJoinPool.common.externalHelpComplete( in externalInterruptibleAwaitDone()
357 ForkJoinPool.common.tryExternalUnpush(this) ? doExec() : in externalInterruptibleAwaitDone()
381 int s; Thread t; ForkJoinWorkerThread wt; ForkJoinPool.WorkQueue w; in doJoin()
694 ForkJoinPool.common.externalPush(this); in fork()
1030 ForkJoinPool.common.externalHelpComplete( in get()
1032 ForkJoinPool.common.tryExternalUnpush(this) ? in get()
1094 ForkJoinPool.quiesceCommonPool(); in helpQuiesce()
1129 public static ForkJoinPool getPool() { in getPool()
[all …]
DForkJoinPool.java167 public class ForkJoinPool extends AbstractExecutorService { class
711 public ForkJoinWorkerThread newThread(ForkJoinPool pool); in newThread()
720 public final ForkJoinWorkerThread newThread(ForkJoinPool pool) { in newThread()
820 final ForkJoinPool pool; // the containing pool (may be null)
829 WorkQueue(ForkJoinPool pool, ForkJoinWorkerThread owner) { in WorkQueue()
876 ForkJoinPool p = pool; in push()
1173 final void transferStealCount(ForkJoinPool p) { in transferStealCount()
1388 static final ForkJoinPool common;
2388 Thread t; ForkJoinWorkerThread wt; ForkJoinPool pool; WorkQueue q; in getSurplusQueuedTaskCount()
2574 ForkJoinPool p = common; in commonSubmitterQueue()
[all …]
DExecutors.java117 return new ForkJoinPool in newWorkStealingPool()
119 ForkJoinPool.defaultForkJoinWorkerThreadFactory, in newWorkStealingPool()
133 return new ForkJoinPool in newWorkStealingPool()
135 ForkJoinPool.defaultForkJoinWorkerThreadFactory, in newWorkStealingPool()
DCountedCompleter.java713 ForkJoinPool.common.externalHelpComplete(this, maxTasks); in helpComplete()
DPhaser.java1062 ForkJoinPool.managedBlock(node); in internalAwaitAdvance()
1084 static final class QNode implements ForkJoinPool.ManagedBlocker {
DCompletableFuture.java398 (ForkJoinPool.getCommonPoolParallelism() > 1);
405 ForkJoinPool.commonPool() : new ThreadPerTaskExecutor();
417 if (!USE_COMMON_POOL && e == ForkJoinPool.commonPool()) in screenExecutor()
1690 implements ForkJoinPool.ManagedBlocker {
1752 ForkJoinPool.managedBlock(q); in waitingGet()
1796 ForkJoinPool.managedBlock(q); in timedGet()
DConcurrentHashMap.java3702 int sp = ForkJoinPool.getCommonPoolParallelism() << 2; // slack of 4 in batchFor()
/libcore/ojluni/src/main/java/java/util/stream/
DAbstractTask.java29 import java.util.concurrent.ForkJoinPool;
97 static final int LEAF_TARGET = ForkJoinPool.getCommonPoolParallelism() << 2;
/libcore/ojluni/src/main/java/java/util/
DArrays.java30 import java.util.concurrent.ForkJoinPool;
468 (p = ForkJoinPool.getCommonPoolParallelism()) == 1) in parallelSort()
508 (p = ForkJoinPool.getCommonPoolParallelism()) == 1) in parallelSort()
538 (p = ForkJoinPool.getCommonPoolParallelism()) == 1) in parallelSort()
578 (p = ForkJoinPool.getCommonPoolParallelism()) == 1) in parallelSort()
608 (p = ForkJoinPool.getCommonPoolParallelism()) == 1) in parallelSort()
648 (p = ForkJoinPool.getCommonPoolParallelism()) == 1) in parallelSort()
678 (p = ForkJoinPool.getCommonPoolParallelism()) == 1) in parallelSort()
718 (p = ForkJoinPool.getCommonPoolParallelism()) == 1) in parallelSort()
748 (p = ForkJoinPool.getCommonPoolParallelism()) == 1) in parallelSort()
[all …]
DArrayPrefixHelpers.java39 import java.util.concurrent.ForkJoinPool;
121 (p = (hi - lo) / (ForkJoinPool.getCommonPoolParallelism() << 3)) in CumulateTask()
273 (p = (hi - lo) / (ForkJoinPool.getCommonPoolParallelism() << 3)) in LongCumulateTask()
423 (p = (hi - lo) / (ForkJoinPool.getCommonPoolParallelism() << 3)) in DoubleCumulateTask()
573 (p = (hi - lo) / (ForkJoinPool.getCommonPoolParallelism() << 3)) in IntCumulateTask()
/libcore/harmony-tests/src/test/java/org/apache/harmony/tests/java/util/
DArraysTest.java37 import java.util.concurrent.ForkJoinPool;
4588 if (ForkJoinPool.getCommonPoolParallelism() > 1) { in test_parallelSort$B()
4645 if (ForkJoinPool.getCommonPoolParallelism() > 1) { in test_parallelSort$BII()
4688 if (ForkJoinPool.getCommonPoolParallelism() > 1) { in test_parallelSort$C()
4746 if (ForkJoinPool.getCommonPoolParallelism() > 1) { in test_parallelSort$CII()
4789 if (ForkJoinPool.getCommonPoolParallelism() > 1) { in test_parallelSort$S()
4847 if (ForkJoinPool.getCommonPoolParallelism() > 1) { in test_parallelSort$SII()
4890 if (ForkJoinPool.getCommonPoolParallelism() > 1) { in test_parallelSort$I()
4948 if (ForkJoinPool.getCommonPoolParallelism() > 1) { in test_parallelSort$III()
4990 if (ForkJoinPool.getCommonPoolParallelism() > 1) { in test_parallelSort$J()
[all …]
/libcore/ojluni/annotations/sdk/nullability/java/util/
DArrays.annotated.java31 import java.util.concurrent.ForkJoinPool;
/libcore/
Dopenjdk_java_files.bp954 "ojluni/src/main/java/java/util/concurrent/ForkJoinPool.java",