HomeSort by relevance Sort by last modified time
    Searched refs:ForkJoinPool (Results 1 - 13 of 13) sorted by null

  /libcore/luni/src/main/java/java/util/concurrent/
ForkJoinWorkerThread.java 10 * A thread managed by a {@link ForkJoinPool}, which executes
17 * custom {@link ForkJoinPool.ForkJoinWorkerThreadFactory} to
18 * {@linkplain ForkJoinPool#ForkJoinPool use it} in a {@code ForkJoinPool}.
27 * of class ForkJoinPool.
37 final ForkJoinPool pool; // the pool this thread works in
38 final ForkJoinPool.WorkQueue workQueue; // work-stealing mechanics
46 protected ForkJoinWorkerThread(ForkJoinPool pool) {
58 public ForkJoinPool getPool()
    [all...]
ForkJoinTask.java 27 * Abstract base class for tasks that run within a {@link ForkJoinPool}.
31 * ForkJoinPool, at the price of some usage limitations.
34 * explicitly submitted to a {@link ForkJoinPool}, or, if not already
36 * ForkJoinPool.commonPool()} via {@link #fork}, {@link #invoke}, or
80 * ForkJoinPool.ManagedBlocker} API is used, or the number of possibly
82 * ForkJoinPool#getParallelism} level, the pool cannot guarantee that
183 * See the internal documentation of class ForkJoinPool for a
186 * to methods in ForkJoinWorkerThread and ForkJoinPool.
269 * ForkJoinPool. Other variants are directly incorporated into
285 ForkJoinPool cp = ForkJoinPool.common
    [all...]
Executors.java 83 return new ForkJoinPool
85 ForkJoinPool.defaultForkJoinWorkerThreadFactory,
98 return new ForkJoinPool
100 ForkJoinPool.defaultForkJoinWorkerThreadFactory,
ForkJoinPool.java 26 * A {@code ForkJoinPool} provides the entry point for submissions
30 * <p>A {@code ForkJoinPool} differs from other kinds of {@link
39 * ForkJoinPool}s may also be appropriate for use with event-style
50 * ForkJoinPool} may be constructed with a given target parallelism
107 * <li>{@code java.util.concurrent.ForkJoinPool.common.parallelism}
109 * <li>{@code java.util.concurrent.ForkJoinPool.common.threadFactory}
111 * <li>{@code java.util.concurrent.ForkJoinPool.common.exceptionHandler}
132 public class ForkJoinPool extends AbstractExecutorService {
470 * ForkJoinPool, ForkJoinWorkerThread, and ForkJoinTask. The
472 * ForkJoinPool, so are directly accessed. There is little poin
    [all...]
Phaser.java 71 * also be used by tasks executing in a {@link ForkJoinPool},
    [all...]
ConcurrentHashMap.java 25 import java.util.concurrent.ForkJoinPool;
    [all...]
  /libcore/jsr166-tests/src/test/java/jsr166/
ForkJoinPoolTest.java 22 import java.util.concurrent.ForkJoinPool;
65 public FailingFJWSubclass(ForkJoinPool p) { super(p) ; }
70 implements ForkJoinPool.ForkJoinWorkerThreadFactory {
72 public ForkJoinWorkerThread newThread(ForkJoinPool p) {
78 static class SubFJP extends ForkJoinPool { // to expose protected
88 static class ManagedLocker implements ForkJoinPool.ManagedBlocker {
160 ForkJoinPool p = new ForkJoinPool(1);
162 assertSame(ForkJoinPool.defaultForkJoinWorkerThreadFactory,
183 new ForkJoinPool(-1)
    [all...]
RecursiveActionTest.java 13 import java.util.concurrent.ForkJoinPool;
26 private static ForkJoinPool mainPool() {
27 return new ForkJoinPool();
30 private static ForkJoinPool singletonPool() {
31 return new ForkJoinPool(1);
34 private static ForkJoinPool asyncSingletonPool() {
35 return new ForkJoinPool(1,
36 ForkJoinPool.defaultForkJoinWorkerThreadFactory,
40 private void testInvokeOnPool(ForkJoinPool pool, RecursiveAction a) {
326 * join/quietlyJoin of a forked task when not in ForkJoinPool
    [all...]
RecursiveTaskTest.java 12 import java.util.concurrent.ForkJoinPool;
23 private static ForkJoinPool mainPool() {
24 return new ForkJoinPool();
27 private static ForkJoinPool singletonPool() {
28 return new ForkJoinPool(1);
31 private static ForkJoinPool asyncSingletonPool() {
32 return new ForkJoinPool(1,
33 ForkJoinPool.defaultForkJoinWorkerThreadFactory,
37 private <T> T testInvokeOnPool(ForkJoinPool pool, RecursiveTask<T> a) {
543 final ForkJoinPool mainPool = mainPool()
    [all...]
ForkJoinTaskTest.java 11 import java.util.concurrent.ForkJoinPool;
29 private static ForkJoinPool mainPool() {
30 return new ForkJoinPool(mainPoolSize);
33 private static ForkJoinPool singletonPool() {
34 return new ForkJoinPool(1);
37 private static ForkJoinPool asyncSingletonPool() {
38 return new ForkJoinPool(1,
39 ForkJoinPool.defaultForkJoinWorkerThreadFactory,
43 private void testInvokeOnPool(ForkJoinPool pool, RecursiveAction a) {
698 final ForkJoinPool mainPool = mainPool()
    [all...]
CountedCompleterTest.java 11 import java.util.concurrent.ForkJoinPool;
32 private static ForkJoinPool mainPool() {
33 return new ForkJoinPool(mainPoolSize);
36 private static ForkJoinPool singletonPool() {
37 return new ForkJoinPool(1);
40 private static ForkJoinPool asyncSingletonPool() {
41 return new ForkJoinPool(1,
42 ForkJoinPool.defaultForkJoinWorkerThreadFactory,
46 private void testInvokeOnPool(ForkJoinPool pool, ForkJoinTask a) {
918 final ForkJoinPool mainPool = mainPool()
    [all...]
  /external/proguard/examples/
scala.pro 56 -keepclassmembernames class scala.concurrent.forkjoin.ForkJoinPool {
60 scala.concurrent.forkjoin.ForkJoinPool$WaitQueueNode syncStack;
61 scala.concurrent.forkjoin.ForkJoinPool$WaitQueueNode spareStack;
  /prebuilts/tools/common/proguard/proguard4.7/examples/
scala.pro 56 -keepclassmembernames class scala.concurrent.forkjoin.ForkJoinPool {
60 scala.concurrent.forkjoin.ForkJoinPool$WaitQueueNode syncStack;
61 scala.concurrent.forkjoin.ForkJoinPool$WaitQueueNode spareStack;

Completed in 102 milliseconds