Home
last modified time | relevance | path

Searched refs:pool (Results 1 – 9 of 9) sorted by relevance

/libcore/luni/src/main/java/java/util/concurrent/
DForkJoinWorkerThread.java37 final ForkJoinPool pool; // the pool this thread works in field in ForkJoinWorkerThread
46 protected ForkJoinWorkerThread(ForkJoinPool pool) { in ForkJoinWorkerThread() argument
49 this.pool = pool; in ForkJoinWorkerThread()
50 this.workQueue = pool.registerWorker(this); in ForkJoinWorkerThread()
59 return pool; in getPool()
108 pool.runWorker(workQueue); in run()
118 pool.deregisterWorker(this, exception); in run()
DForkJoinTask.java357 wt.pool.awaitJoin(w, this) : in doJoin()
370 (wt = (ForkJoinWorkerThread)t).pool.awaitJoin(wt.workQueue, this) : in doInvoke()
999 p = wt.pool; in get()
1089 wt.pool.helpQuiescePool(wt.workQueue); in helpQuiesce()
1128 ((ForkJoinWorkerThread) t).pool : null; in getPool()
1285 (wt = (ForkJoinWorkerThread)t).pool.nextTaskFor(wt.workQueue) : in pollTask()
DForkJoinPool.java530 public ForkJoinWorkerThread newThread(ForkJoinPool pool); in newThread() argument
539 public final ForkJoinWorkerThread newThread(ForkJoinPool pool) { in newThread() argument
540 return new ForkJoinWorkerThread(pool); in newThread()
640 final ForkJoinPool pool; // the containing pool (may be null) field in ForkJoinPool.WorkQueue
649 WorkQueue(ForkJoinPool pool, ForkJoinWorkerThread owner, int mode, in WorkQueue() argument
651 this.pool = pool; in WorkQueue()
697 (p = pool).signalWork(p.workQueues, this); in push()
2172 Thread t; ForkJoinWorkerThread wt; ForkJoinPool pool; WorkQueue q; in getSurplusQueuedTaskCount() local
2174 int p = (pool = (wt = (ForkJoinWorkerThread)t).pool).parallelism; in getSurplusQueuedTaskCount()
2176 int a = (int)(pool.ctl >> AC_SHIFT) + p; in getSurplusQueuedTaskCount()
[all …]
/libcore/luni/src/main/java/org/apache/harmony/security/asn1/
DBerInputStream.java796 private Object[][] pool; field in BerInputStream
799 if (pool == null) { in put()
800 pool = new Object[2][10]; in put()
804 for (; i < pool[0].length && pool[0][i] != null; i++) { in put()
805 if (pool[0][i] == key) { in put()
806 pool[1][i] = entry; in put()
811 if (i == pool[0].length) { in put()
812 Object[][] newPool = new Object[pool[0].length * 2][2]; in put()
813 System.arraycopy(pool[0], 0, newPool[0], 0, pool[0].length); in put()
814 System.arraycopy(pool[1], 0, newPool[1], 0, pool[0].length); in put()
[all …]
/libcore/luni/src/main/java/libcore/internal/
DStringPool.java26 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/jsr166-tests/src/test/java/jsr166/
DRecursiveTaskTest.java37 private <T> T testInvokeOnPool(ForkJoinPool pool, RecursiveTask<T> a) { in testInvokeOnPool() argument
41 T result = pool.invoke(a); in testInvokeOnPool()
46 joinPool(pool); in testInvokeOnPool()
DRecursiveActionTest.java40 private void testInvokeOnPool(ForkJoinPool pool, RecursiveAction a) { in testInvokeOnPool() argument
44 assertNull(pool.invoke(a)); in testInvokeOnPool()
48 joinPool(pool); in testInvokeOnPool()
DForkJoinTaskTest.java43 private void testInvokeOnPool(ForkJoinPool pool, RecursiveAction a) { in testInvokeOnPool() argument
52 assertNull(pool.invoke(a)); in testInvokeOnPool()
61 joinPool(pool); in testInvokeOnPool()
DCountedCompleterTest.java46 private void testInvokeOnPool(ForkJoinPool pool, ForkJoinTask a) { in testInvokeOnPool() argument
55 assertNull(pool.invoke(a)); in testInvokeOnPool()
64 joinPool(pool); in testInvokeOnPool()