Home
last modified time | relevance | path

Searched defs:pool (Results 1 – 25 of 42) 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
DForkJoinWorkerThreadTest.java34 final ForkJoinPool pool = new ForkJoinPool(); in testCtorWithThreadGroup() local
41 public WorkerThreadImpl(ThreadGroup group, ForkJoinPool pool, in WorkerThreadImpl()
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/test/java/util/concurrent/tck/
DForkJoinPool20Test.java74 try (var pool = new ForkJoinPool()) { in testExternalSubmit1()
93 try (var pool = new ForkJoinPool(1)) { in testExternalSubmit2()
114 try (var pool = new ForkJoinPool()) { in testExternalSubmitReturnsTask()
125 try (var pool = new ForkJoinPool()) { in testExternalSubmitWithNull()
135 try (var pool = new ForkJoinPool()) { in testExternalSubmitWhenShutdown()
148 try (var pool = new ForkJoinPool(1)) { in testSubmit()
177 try (var pool = new ForkJoinPool(1)) { in testGetQueuedTaskCount1()
201 try (var pool = new ForkJoinPool(2)) { in testGetQueuedTaskCount2()
227 static ForkJoinWorkerThread submitBusyTask(ForkJoinPool pool) throws Exception { in submitBusyTask()
DJSR166TestCase.java1134 private final ExecutorService pool; field in JSR166TestCase.PoolCleaner
1135 public PoolCleaner(ExecutorService pool) { this.pool = pool; } in PoolCleaner()
1144 public PoolCleanerWithReleaser(ExecutorService pool, Runnable releaser) { in PoolCleanerWithReleaser()
1157 PoolCleaner cleaner(ExecutorService pool) { in cleaner()
1161 PoolCleaner cleaner(ExecutorService pool, Runnable releaser) { in cleaner()
1165 PoolCleaner cleaner(ExecutorService pool, CountDownLatch latch) { in cleaner()
DForkJoinTask8Test.java116 private void testInvokeOnPool(ForkJoinPool pool, RecursiveAction a) { in testInvokeOnPool()
970 testInvokeOnPool(pool, a); in testInvokeOnPool() argument
DForkJoinPool19Test.java112 private void testInvokeOnPool(ForkJoinPool pool, RecursiveAction a) { in testInvokeOnPool()
535 ForkJoinPool pool = null; in testClose() local
550 ForkJoinPool pool; in testCloseCommonPool() local
DForkJoinTaskTest.java94 private void testInvokeOnPool(ForkJoinPool pool, RecursiveAction a) { in testInvokeOnPool()
DDoubleAccumulatorTest.java174 final ExecutorService pool = Executors.newCachedThreadPool(); in testAccumulateAndGetMT() local
DLongAccumulatorTest.java174 final ExecutorService pool = Executors.newCachedThreadPool(); in testAccumulateAndGetMT() local
/libcore/ojluni/src/main/java/java/util/concurrent/
DForkJoinWorkerThread.java68 final ForkJoinPool pool; // the pool this thread works in field in ForkJoinWorkerThread
74 ForkJoinWorkerThread(ThreadGroup group, ForkJoinPool pool, in ForkJoinWorkerThread()
103 protected ForkJoinWorkerThread(ThreadGroup group, ForkJoinPool pool, in ForkJoinWorkerThread()
114 protected ForkJoinWorkerThread(ForkJoinPool pool) { in ForkJoinWorkerThread()
215 InnocuousForkJoinWorkerThread(ForkJoinPool pool) { in InnocuousForkJoinWorkerThread()
DForkJoinPool.java980 public ForkJoinWorkerThread newThread(ForkJoinPool pool); in newThread()
990 public final ForkJoinWorkerThread newThread(ForkJoinPool pool) { in newThread()
1014 static ForkJoinWorkerThread newRegularWithACC(ForkJoinPool pool) { in newRegularWithACC()
1032 static ForkJoinWorkerThread newCommonWithACC(ForkJoinPool pool) { in newCommonWithACC()
/libcore/ojluni/annotations/flagged_api/java/util/concurrent/
DForkJoinWorkerThread.annotated.java43 protected ForkJoinWorkerThread(java.lang.ThreadGroup group, java.util.concurrent.ForkJoinPool pool,… in ForkJoinWorkerThread()
45 protected ForkJoinWorkerThread(java.util.concurrent.ForkJoinPool pool) { throw new RuntimeException… in ForkJoinWorkerThread()
/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
/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