| /libcore/luni/src/main/java/java/util/concurrent/ |
| D | ForkJoinWorkerThread.java | 44 final ForkJoinPool pool; // the pool this thread works in field in ForkJoinWorkerThread
53 protected ForkJoinWorkerThread(ForkJoinPool pool) { in ForkJoinWorkerThread() argument
56 this.pool = pool; in ForkJoinWorkerThread()
57 this.workQueue = pool.registerWorker(this); in ForkJoinWorkerThread()
63 ForkJoinWorkerThread(ForkJoinPool pool, ThreadGroup threadGroup, in ForkJoinWorkerThread() argument
68 this.pool = pool; in ForkJoinWorkerThread()
69 this.workQueue = pool.registerWorker(this); in ForkJoinWorkerThread()
78 return pool; in getPool()
128 pool.runWorker(workQueue); in run()
138 pool.deregisterWorker(this, exception); in run()
[all …]
|
| D | ForkJoinTask.java | 357 wt.pool.awaitJoin(w, this, 0L) : in doJoin()
370 (wt = (ForkJoinWorkerThread)t).pool. in doInvoke()
998 s = wt.pool.awaitJoin(wt.workQueue, this, deadline); in get()
1062 wt.pool.helpQuiescePool(wt.workQueue); in helpQuiesce()
1103 ((ForkJoinWorkerThread) t).pool : null; in getPool()
1260 (wt = (ForkJoinWorkerThread)t).pool.nextTaskFor(wt.workQueue) : in pollTask()
1280 ((ForkJoinWorkerThread)t).pool.pollSubmission() : null; in pollSubmission()
|
| D | ForkJoinPool.java | 681 public ForkJoinWorkerThread newThread(ForkJoinPool pool); in newThread() argument
690 public final ForkJoinWorkerThread newThread(ForkJoinPool pool) { in newThread() argument
691 return new ForkJoinWorkerThread(pool); in newThread()
789 final ForkJoinPool pool; // the containing pool (may be null) field in ForkJoinPool.WorkQueue
797 WorkQueue(ForkJoinPool pool, ForkJoinWorkerThread owner) { in WorkQueue() argument
798 this.pool = pool; in WorkQueue()
844 ForkJoinPool p = pool; in push()
1132 transferStealCount(pool); in runTask()
2356 Thread t; ForkJoinWorkerThread wt; ForkJoinPool pool; WorkQueue q; in getSurplusQueuedTaskCount() local
2358 int p = (pool = (wt = (ForkJoinWorkerThread)t).pool).config & SMASK; in getSurplusQueuedTaskCount()
[all …]
|
| D | CountedCompleter.java | 681 (wt = (ForkJoinWorkerThread)t).pool. in helpComplete()
|
| /libcore/jsr166-tests/src/test/java/jsr166/ |
| D | ForkJoinTask8Test.java | 80 private void testInvokeOnPool(ForkJoinPool pool, RecursiveAction a) { in testInvokeOnPool() argument
81 try (PoolCleaner cleaner = cleaner(pool)) { in testInvokeOnPool()
89 assertNull(pool.invoke(a)); in testInvokeOnPool()
388 public void testInvoke(ForkJoinPool pool) {
395 testInvokeOnPool(pool, a);
409 public void testQuietlyInvoke(ForkJoinPool pool) {
416 testInvokeOnPool(pool, a);
428 public void testForkJoin(ForkJoinPool pool) {
436 testInvokeOnPool(pool, a);
448 public void testForkGet(ForkJoinPool pool) {
[all …]
|
| D | JSR166TestCase.java | 855 private final ExecutorService pool; field in JSR166TestCase.PoolCleaner
856 public PoolCleaner(ExecutorService pool) { this.pool = pool; } in PoolCleaner() argument
857 public void close() { joinPool(pool); } in close()
865 public PoolCleanerWithReleaser(ExecutorService pool, Runnable releaser) { in PoolCleanerWithReleaser() argument
866 super(pool); in PoolCleanerWithReleaser()
878 PoolCleaner cleaner(ExecutorService pool) { in cleaner() argument
879 return new PoolCleaner(pool); in cleaner()
882 PoolCleaner cleaner(ExecutorService pool, Runnable releaser) { in cleaner() argument
883 return new PoolCleanerWithReleaser(pool, releaser); in cleaner()
886 PoolCleaner cleaner(ExecutorService pool, CountDownLatch latch) { in cleaner() argument
[all …]
|
| D | Collection8Test.java | 82 final ExecutorService pool = Executors.newCachedThreadPool(); in testForEachConcurrentStressTest() local
83 try (PoolCleaner cleaner = cleaner(pool, done)) { in testForEachConcurrentStressTest()
95 f1 = pool.submit(checkElt); in testForEachConcurrentStressTest()
96 f2 = pool.submit(addRemove); in testForEachConcurrentStressTest()
|
| D | DoubleAccumulatorTest.java | 127 final ExecutorService pool = Executors.newCachedThreadPool(); in testAccumulateAndGetMT() local
131 pool.execute(new AccTask(a, phaser, incs)); in testAccumulateAndGetMT()
137 pool.shutdown(); in testAccumulateAndGetMT()
|
| D | LongAccumulatorTest.java | 127 final ExecutorService pool = Executors.newCachedThreadPool(); in testAccumulateAndGetMT() local
131 pool.execute(new AccTask(a, phaser, incs)); in testAccumulateAndGetMT()
137 pool.shutdown(); in testAccumulateAndGetMT()
|
| D | DoubleAdderTest.java | 139 final ExecutorService pool = Executors.newCachedThreadPool(); in testAddAndSumMT() local
143 pool.execute(new AdderTask(a, barrier, incs)); in testAddAndSumMT()
149 pool.shutdown(); in testAddAndSumMT()
|
| D | LongAdderTest.java | 162 final ExecutorService pool = Executors.newCachedThreadPool(); in testAddAndSumMT() local
166 pool.execute(new AdderTask(a, barrier, incs)); in testAddAndSumMT()
172 pool.shutdown(); in testAddAndSumMT()
|
| D | FutureTaskTest.java | 822 final ExecutorService pool = Executors.newFixedThreadPool(10); in testGet_NegativeInfinityTimeout() local
834 futures.add(pool.submit(r)); in testGet_NegativeInfinityTimeout()
836 joinPool(pool); in testGet_NegativeInfinityTimeout()
|
| D | RecursiveTaskTest.java | 48 private <T> T testInvokeOnPool(ForkJoinPool pool, RecursiveTask<T> a) { in testInvokeOnPool() argument
49 try (PoolCleaner cleaner = cleaner(pool)) { in testInvokeOnPool()
52 T result = pool.invoke(a); in testInvokeOnPool()
|
| D | RecursiveActionTest.java | 52 private void testInvokeOnPool(ForkJoinPool pool, RecursiveAction a) { in testInvokeOnPool() argument
53 try (PoolCleaner cleaner = cleaner(pool)) { in testInvokeOnPool()
56 assertNull(pool.invoke(a)); in testInvokeOnPool()
|
| D | ForkJoinTaskTest.java | 57 private void testInvokeOnPool(ForkJoinPool pool, RecursiveAction a) { in testInvokeOnPool() argument
58 try (PoolCleaner cleaner = cleaner(pool)) { in testInvokeOnPool()
66 assertNull(pool.invoke(a)); in testInvokeOnPool()
|
| D | CountedCompleterTest.java | 55 private void testInvokeOnPool(ForkJoinPool pool, ForkJoinTask a) { in testInvokeOnPool() argument
56 try (PoolCleaner cleaner = cleaner(pool)) { in testInvokeOnPool()
64 assertNull(pool.invoke(a)); in testInvokeOnPool()
|
| /libcore/luni/src/main/java/libcore/internal/ |
| D | StringPool.java | 26 private final String[] pool = new String[512]; field in StringPool
53 int index = hashCode & (pool.length - 1); in get()
55 String pooled = pool[index]; in get()
61 pool[index] = result; in get()
|
| /libcore/ojluni/src/main/java/sun/util/ |
| D | LocaleServiceProviderPool.java | 110 LocaleServiceProviderPool pool = poolOfPools.get(providerClass); in getPool() local
111 if (pool == null) { in getPool()
114 pool = poolOfPools.putIfAbsent(providerClass, newPool); in getPool()
115 if (pool == null) { in getPool()
116 pool = newPool; in getPool()
120 return pool; in getPool()
186 LocaleServiceProviderPool pool =
188 all.addAll(pool.getProviderLocales()); in pool.getProviderLocales()
|
| /libcore/ojluni/src/main/java/sun/net/spi/ |
| D | DefaultProxySelector.java | 111 NonProxyInfo(String p, String s, RegexpPool pool, String d) { in NonProxyInfo() argument
114 hostsPool = pool; in NonProxyInfo()
241 RegexpPool pool = new RegexpPool(); in select()
245 … pool.add(st.nextToken().toLowerCase(), Boolean.TRUE); in select()
249 nprop.hostsPool = pool; in select()
|
| /libcore/ojluni/src/main/java/java/text/ |
| D | DateFormat.java | 584 LocaleServiceProviderPool pool = in getAvailableLocales() local
586 return pool.getAvailableLocales(); in getAvailableLocales()
769 LocaleServiceProviderPool pool = in get() local
771 if (pool.hasProviders()) { in get()
772 DateFormat providersInstance = pool.getLocalizedObject( in get()
|
| D | NumberFormat.java | 485 LocaleServiceProviderPool pool = in getAvailableLocales() local
487 return pool.getAvailableLocales(); in getAvailableLocales()
733 LocaleServiceProviderPool pool = in getInstance() local
735 if (pool.hasProviders()) { in getInstance()
736 NumberFormat providersInstance = pool.getLocalizedObject( in getInstance()
|
| D | DateFormatSymbols.java | 372 LocaleServiceProviderPool pool= in getAvailableLocales() local
374 return pool.getAvailableLocales(); in getAvailableLocales()
430 LocaleServiceProviderPool pool = in getProviderInstance() local
432 if (pool.hasProviders()) { in getProviderInstance()
433 providersInstance = pool.getLocalizedObject( in getProviderInstance()
|
| D | DecimalFormatSymbols.java | 114 LocaleServiceProviderPool pool = in getAvailableLocales() local
116 return pool.getAvailableLocales(); in getAvailableLocales()
149 LocaleServiceProviderPool pool = in getInstance() local
151 if (pool.hasProviders()) { in getInstance()
152 DecimalFormatSymbols providersInstance = pool.getLocalizedObject( in getInstance()
|