Home
last modified time | relevance | path

Searched defs:pool (Results 1 – 25 of 38) sorted by relevance

12

/libcore/luni/src/test/java/libcore/java/util/concurrent/
DForkJoinPoolTest.java38 final ForkJoinPool pool = new ForkJoinPool(); in testSubmit() local
51 final ForkJoinPool pool = new ForkJoinPool(); in testGetRunningThreadCount() local
84 ForkJoinPool pool = new ForkJoinPool(0, in testConstructor_withKeepAliveTime() local
99 ForkJoinPool pool = new ForkJoinPool(-1, in testConstructor_withKeepAliveTime() local
114 ForkJoinPool pool = new ForkJoinPool(8, in testConstructor_withKeepAliveTime() local
129 ForkJoinPool pool = new ForkJoinPool(8, in testConstructor_withKeepAliveTime() local
144 ForkJoinPool pool = new ForkJoinPool(8, in testConstructor_withKeepAliveTime() local
158 ForkJoinPool pool = new ForkJoinPool(8, in testConstructor_withKeepAliveTime() local
DForkJoinTaskTest.java43 final ForkJoinPool pool = new ForkJoinPool(1); in testAdaptToRunnableWithResult() local
62 final ForkJoinPool pool = new ForkJoinPool(1); in testAdaptToCallable() local
81 final ForkJoinPool pool = new ForkJoinPool(1); in testAdaptToCallableThrowsException() local
DCountedCompleterTest.java137 final ForkJoinPool pool; in completeAllChildren() field in CountedCompleterTest.MainTask
141 MainTask(ForkJoinPool pool, int lo, int hi) { in completeAllChildren()
174 ForkJoinPool pool = new ForkJoinPool(1); in completeAllChildren() local
/libcore/ojluni/src/main/java/java/util/concurrent/
DForkJoinWorkerThread.java66 final ForkJoinPool pool; // the pool this thread works in field in ForkJoinWorkerThread
72 ForkJoinWorkerThread(ThreadGroup group, ForkJoinPool pool, in ForkJoinWorkerThread()
92 /* TODO: protected */ ForkJoinWorkerThread(ThreadGroup group, ForkJoinPool pool) { in ForkJoinWorkerThread()
102 protected ForkJoinWorkerThread(ForkJoinPool pool) { in ForkJoinWorkerThread()
200 InnocuousForkJoinWorkerThread(ForkJoinPool pool) { in InnocuousForkJoinWorkerThread()
DForkJoinPool.java795 public ForkJoinWorkerThread newThread(ForkJoinPool pool); in newThread()
811 public final ForkJoinWorkerThread newThread(ForkJoinPool pool) { in newThread()
DForkJoinTask.java399 private int awaitDone(ForkJoinPool pool, boolean ran, in awaitDone()
1037 final void awaitPoolInvoke(ForkJoinPool pool) { in awaitPoolInvoke()
1040 final void awaitPoolInvoke(ForkJoinPool pool, long nanos) { in awaitPoolInvoke()
1043 final V joinForPoolInvoke(ForkJoinPool pool) { in joinForPoolInvoke()
1049 final V getForPoolInvoke(ForkJoinPool pool) in getForPoolInvoke()
1056 final V getForPoolInvoke(ForkJoinPool pool, long nanos) in getForPoolInvoke()
/libcore/ojluni/src/main/java/sun/nio/ch/
DAsynchronousChannelGroupImpl.java55 private final ThreadPool pool; field in AsynchronousChannelGroupImpl
73 ThreadPool pool) in AsynchronousChannelGroupImpl()
DPort.java57 Port(AsynchronousChannelProvider provider, ThreadPool pool) { in Port()
/libcore/jsr166-tests/src/test/java/jsr166/
DForkJoinTask8Test.java80 private void testInvokeOnPool(ForkJoinPool pool, RecursiveAction a) { in testInvokeOnPool()
887 testInvokeOnPool(pool, a); in testInvokeOnPool() argument
DJSR166TestCase.java855 private final ExecutorService pool; field in JSR166TestCase.PoolCleaner
856 public PoolCleaner(ExecutorService pool) { this.pool = pool; } in PoolCleaner()
865 public PoolCleanerWithReleaser(ExecutorService pool, Runnable releaser) { in PoolCleanerWithReleaser()
878 PoolCleaner cleaner(ExecutorService pool) { in cleaner()
882 PoolCleaner cleaner(ExecutorService pool, Runnable releaser) { in cleaner()
886 PoolCleaner cleaner(ExecutorService pool, CountDownLatch latch) { in cleaner()
DForkJoinTaskTest.java57 private void testInvokeOnPool(ForkJoinPool pool, RecursiveAction a) { in testInvokeOnPool()
DCollection8Test.java82 final ExecutorService pool = Executors.newCachedThreadPool(); in testForEachConcurrentStressTest() local
DLongAccumulatorTest.java127 final ExecutorService pool = Executors.newCachedThreadPool(); in testAccumulateAndGetMT() local
DDoubleAccumulatorTest.java127 final ExecutorService pool = Executors.newCachedThreadPool(); in testAccumulateAndGetMT() local
DDoubleAdderTest.java139 final ExecutorService pool = Executors.newCachedThreadPool(); in testAddAndSumMT() local
DLongAdderTest.java162 final ExecutorService pool = Executors.newCachedThreadPool(); in testAddAndSumMT() local
/libcore/ojluni/src/test/java/util/concurrent/tck/
DForkJoinTask8Test.java103 private void testInvokeOnPool(ForkJoinPool pool, RecursiveAction a) { in testInvokeOnPool()
910 testInvokeOnPool(pool, a); in testInvokeOnPool() argument
DJSR166TestCase.java986 private final ExecutorService pool; field in JSR166TestCase.PoolCleaner
987 public PoolCleaner(ExecutorService pool) { this.pool = pool; } in PoolCleaner()
996 public PoolCleanerWithReleaser(ExecutorService pool, Runnable releaser) { in PoolCleanerWithReleaser()
1009 PoolCleaner cleaner(ExecutorService pool) { in cleaner()
1013 PoolCleaner cleaner(ExecutorService pool, Runnable releaser) { in cleaner()
1017 PoolCleaner cleaner(ExecutorService pool, CountDownLatch latch) { in cleaner()
DForkJoinTaskTest.java79 private void testInvokeOnPool(ForkJoinPool pool, RecursiveAction a) { in testInvokeOnPool()
DDoubleAccumulatorTest.java150 final ExecutorService pool = Executors.newCachedThreadPool(); in testAccumulateAndGetMT() local
DLongAccumulatorTest.java150 final ExecutorService pool = Executors.newCachedThreadPool(); in testAccumulateAndGetMT() local
DDoubleAdderTest.java162 final ExecutorService pool = Executors.newCachedThreadPool(); in testAddAndSumMT() local
DLongAdderTest.java185 final ExecutorService pool = Executors.newCachedThreadPool(); in testAddAndSumMT() local
/libcore/luni/src/main/java/libcore/internal/
DStringPool.java28 private final String[] pool = new String[512]; field in StringPool
/libcore/ojluni/src/test/java/util/Properties/
DConcurrentLoadAndStoreXML.java93 ExecutorService pool = Executors.newFixedThreadPool(NTASKS); in main() local

12