Home
last modified time | relevance | path

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

/libcore/jsr166-tests/src/test/java/jsr166/
DForkJoinPoolTest.java22 import java.util.concurrent.ForkJoinPool;
65 public FailingFJWSubclass(ForkJoinPool p) { super(p) ; } in FailingFJWSubclass()
70 implements ForkJoinPool.ForkJoinWorkerThreadFactory {
72 public ForkJoinWorkerThread newThread(ForkJoinPool p) { in newThread()
78 static class SubFJP extends ForkJoinPool { // to expose protected
88 static class ManagedLocker implements ForkJoinPool.ManagedBlocker {
160 ForkJoinPool p = new ForkJoinPool(1); in testDefaultInitialState()
162 assertSame(ForkJoinPool.defaultForkJoinWorkerThreadFactory, in testDefaultInitialState()
183 new ForkJoinPool(-1); in testConstructor1()
193 new ForkJoinPool(1, null, null, false); in testConstructor2()
[all …]
DRecursiveActionTest.java13 import java.util.concurrent.ForkJoinPool;
26 private static ForkJoinPool mainPool() { in mainPool()
27 return new ForkJoinPool(); in mainPool()
30 private static ForkJoinPool singletonPool() { in singletonPool()
31 return new ForkJoinPool(1); in singletonPool()
34 private static ForkJoinPool asyncSingletonPool() { in asyncSingletonPool()
35 return new ForkJoinPool(1, in asyncSingletonPool()
36 ForkJoinPool.defaultForkJoinWorkerThreadFactory, in asyncSingletonPool()
40 private void testInvokeOnPool(ForkJoinPool pool, RecursiveAction a) { in testInvokeOnPool()
704 final ForkJoinPool mainPool = mainPool(); in testGetPool()
[all …]
DRecursiveTaskTest.java12 import java.util.concurrent.ForkJoinPool;
23 private static ForkJoinPool mainPool() { in mainPool()
24 return new ForkJoinPool(); in mainPool()
27 private static ForkJoinPool singletonPool() { in singletonPool()
28 return new ForkJoinPool(1); in singletonPool()
31 private static ForkJoinPool asyncSingletonPool() { in asyncSingletonPool()
32 return new ForkJoinPool(1, in asyncSingletonPool()
33 ForkJoinPool.defaultForkJoinWorkerThreadFactory, in asyncSingletonPool()
37 private <T> T testInvokeOnPool(ForkJoinPool pool, RecursiveTask<T> a) { in testInvokeOnPool()
543 final ForkJoinPool mainPool = mainPool(); in testGetPool()
DForkJoinTaskTest.java11 import java.util.concurrent.ForkJoinPool;
29 private static ForkJoinPool mainPool() { in mainPool()
30 return new ForkJoinPool(mainPoolSize); in mainPool()
33 private static ForkJoinPool singletonPool() { in singletonPool()
34 return new ForkJoinPool(1); in singletonPool()
37 private static ForkJoinPool asyncSingletonPool() { in asyncSingletonPool()
38 return new ForkJoinPool(1, in asyncSingletonPool()
39 ForkJoinPool.defaultForkJoinWorkerThreadFactory, in asyncSingletonPool()
43 private void testInvokeOnPool(ForkJoinPool pool, RecursiveAction a) { in testInvokeOnPool()
698 final ForkJoinPool mainPool = mainPool(); in testGetPool()
DCountedCompleterTest.java11 import java.util.concurrent.ForkJoinPool;
32 private static ForkJoinPool mainPool() { in mainPool()
33 return new ForkJoinPool(mainPoolSize); in mainPool()
36 private static ForkJoinPool singletonPool() { in singletonPool()
37 return new ForkJoinPool(1); in singletonPool()
40 private static ForkJoinPool asyncSingletonPool() { in asyncSingletonPool()
41 return new ForkJoinPool(1, in asyncSingletonPool()
42 ForkJoinPool.defaultForkJoinWorkerThreadFactory, in asyncSingletonPool()
46 private void testInvokeOnPool(ForkJoinPool pool, ForkJoinTask a) { in testInvokeOnPool()
918 final ForkJoinPool mainPool = mainPool(); in testGetPool()
/libcore/luni/src/main/java/java/util/concurrent/
DForkJoinWorkerThread.java37 final ForkJoinPool pool; // the pool this thread works in
38 final ForkJoinPool.WorkQueue workQueue; // work-stealing mechanics
46 protected ForkJoinWorkerThread(ForkJoinPool pool) { in ForkJoinWorkerThread()
58 public ForkJoinPool getPool() { in getPool()
DForkJoinTask.java285 ForkJoinPool cp = ForkJoinPool.common; in externalAwaitDone()
322 ForkJoinPool cp = ForkJoinPool.common; in externalInterruptibleAwaitDone()
352 int s; Thread t; ForkJoinWorkerThread wt; ForkJoinPool.WorkQueue w; in doJoin()
662 ForkJoinPool.common.externalPush(this); in fork()
991 ForkJoinPool cp; in get()
994 ForkJoinPool p = null; in get()
995 ForkJoinPool.WorkQueue w = null; in get()
1003 else if ((cp = ForkJoinPool.common) != null) { in get()
1092 ForkJoinPool.quiesceCommonPool(); in helpQuiesce()
1125 public static ForkJoinPool getPool() { in getPool()
[all …]
DExecutors.java83 return new ForkJoinPool in newWorkStealingPool()
85 ForkJoinPool.defaultForkJoinWorkerThreadFactory, in newWorkStealingPool()
98 return new ForkJoinPool in newWorkStealingPool()
100 ForkJoinPool.defaultForkJoinWorkerThreadFactory, in newWorkStealingPool()
DForkJoinPool.java132 public class ForkJoinPool extends AbstractExecutorService { class
530 public ForkJoinWorkerThread newThread(ForkJoinPool pool); in newThread()
539 public final ForkJoinWorkerThread newThread(ForkJoinPool pool) { in newThread()
640 final ForkJoinPool pool; // the containing pool (may be null)
649 WorkQueue(ForkJoinPool pool, ForkJoinWorkerThread owner, int mode, in WorkQueue()
691 ForkJoinTask<?>[] a; ForkJoinPool p; in push()
1078 static final ForkJoinPool common;
2172 Thread t; ForkJoinWorkerThread wt; ForkJoinPool pool; WorkQueue q; in getSurplusQueuedTaskCount()
2291 Submitter z; ForkJoinPool p; WorkQueue[] ws; int m, r; in commonSubmitterQueue()
2365 public ForkJoinPool() { in ForkJoinPool() method in ForkJoinPool
[all …]
DPhaser.java1038 ForkJoinPool.managedBlock(node); in internalAwaitAdvance()
1060 static final class QNode implements ForkJoinPool.ManagedBlocker {
DConcurrentHashMap.java25 import java.util.concurrent.ForkJoinPool;