/libcore/ojluni/src/main/java/java/util/concurrent/ |
D | ForkJoinWorkerThread.java | 73 final ForkJoinPool pool; // the pool this thread works in field in ForkJoinWorkerThread 82 protected ForkJoinWorkerThread(ForkJoinPool pool) { in ForkJoinWorkerThread() 92 ForkJoinWorkerThread(ForkJoinPool pool, ThreadGroup threadGroup, in ForkJoinWorkerThread() 222 InnocuousForkJoinWorkerThread(ForkJoinPool pool) { in InnocuousForkJoinWorkerThread()
|
D | ForkJoinPool.java | 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) field in ForkJoinPool.WorkQueue 829 WorkQueue(ForkJoinPool pool, ForkJoinWorkerThread owner) { in WorkQueue() 2388 Thread t; ForkJoinWorkerThread wt; ForkJoinPool pool; WorkQueue q; in getSurplusQueuedTaskCount() local 3572 public final ForkJoinWorkerThread newThread(ForkJoinPool pool) { in newThread()
|
/libcore/ojluni/src/main/java/sun/nio/ch/ |
D | AsynchronousChannelGroupImpl.java | 55 private final ThreadPool pool; field in AsynchronousChannelGroupImpl 73 ThreadPool pool) in AsynchronousChannelGroupImpl()
|
D | Port.java | 57 Port(AsynchronousChannelProvider provider, ThreadPool pool) { in Port()
|
D | EPollPort.java | 83 EPollPort(AsynchronousChannelProvider provider, ThreadPool pool) in EPollPort()
|
D | SimpleAsynchronousFileChannelImpl.java | 68 ThreadPool pool) in open()
|
/libcore/jsr166-tests/src/test/java/jsr166/ |
D | ForkJoinTask8Test.java | 80 private void testInvokeOnPool(ForkJoinPool pool, RecursiveAction a) { in testInvokeOnPool() 887 testInvokeOnPool(pool, a); in testInvokeOnPool() argument
|
D | JSR166TestCase.java | 855 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()
|
D | ForkJoinTaskTest.java | 57 private void testInvokeOnPool(ForkJoinPool pool, RecursiveAction a) { in testInvokeOnPool()
|
D | Collection8Test.java | 82 final ExecutorService pool = Executors.newCachedThreadPool(); in testForEachConcurrentStressTest() local
|
D | DoubleAccumulatorTest.java | 127 final ExecutorService pool = Executors.newCachedThreadPool(); in testAccumulateAndGetMT() local
|
D | LongAccumulatorTest.java | 127 final ExecutorService pool = Executors.newCachedThreadPool(); in testAccumulateAndGetMT() local
|
D | DoubleAdderTest.java | 139 final ExecutorService pool = Executors.newCachedThreadPool(); in testAddAndSumMT() local
|
D | LongAdderTest.java | 162 final ExecutorService pool = Executors.newCachedThreadPool(); in testAddAndSumMT() local
|
D | RecursiveTaskTest.java | 48 private <T> T testInvokeOnPool(ForkJoinPool pool, RecursiveTask<T> a) { in testInvokeOnPool()
|
D | FutureTaskTest.java | 822 final ExecutorService pool = Executors.newFixedThreadPool(10); in testGet_NegativeInfinityTimeout() local
|
D | RecursiveActionTest.java | 52 private void testInvokeOnPool(ForkJoinPool pool, RecursiveAction a) { in testInvokeOnPool()
|
D | CountedCompleterTest.java | 55 private void testInvokeOnPool(ForkJoinPool pool, ForkJoinTask a) { in testInvokeOnPool()
|
/libcore/luni/src/main/java/libcore/internal/ |
D | StringPool.java | 29 private final String[] pool = new String[512]; field in StringPool
|
/libcore/ojluni/src/main/java/sun/nio/fs/ |
D | UnixChannelFactory.java | 157 ThreadPool pool) in newAsynchronousFileChannel()
|
D | UnixFileSystemProvider.java | 191 ThreadPool pool = (executor == null) ? null : ThreadPool.wrap(executor, 0); in newAsynchronousFileChannel() local
|