/libcore/luni/src/main/java/libcore/internal/ |
H A D | StringPool.java | 20 * A pool of string instances. Unlike the {@link String#intern() VM's 21 * interned strings}, this pool provides no guarantee of reference equality. 26 private final String[] pool = new String[512]; field in class:StringPool 53 int index = hashCode & (pool.length - 1); 55 String pooled = pool[index]; 61 pool[index] = result;
|
/libcore/ojluni/src/main/java/sun/net/spi/ |
H A D | DefaultProxySelector.java | 111 NonProxyInfo(String p, String s, RegexpPool pool, String d) { argument 114 hostsPool = pool; 241 RegexpPool pool = new RegexpPool(); 245 pool.add(st.nextToken().toLowerCase(), Boolean.TRUE); 249 nprop.hostsPool = pool;
|
/libcore/luni/src/main/java/java/util/concurrent/ |
H A D | ForkJoinWorkerThread.java | 32 * This class just maintains links to its pool and WorkQueue. The 33 * pool field is set immediately upon construction, but the 44 final ForkJoinPool pool; // the pool this thread works in field in class:ForkJoinWorkerThread 48 * Creates a ForkJoinWorkerThread operating in the given pool. 50 * @param pool the pool this thread works in 51 * @throws NullPointerException if pool is null 53 protected ForkJoinWorkerThread(ForkJoinPool pool) { argument 56 this.pool 63 ForkJoinWorkerThread(ForkJoinPool pool, ThreadGroup threadGroup, AccessControlContext acc) argument 193 InnocuousForkJoinWorkerThread(ForkJoinPool pool) argument [all...] |
H A D | ForkJoinPool.java | 29 * <em>work-stealing</em>: all threads in the pool attempt to find and 30 * execute tasks submitted to the pool and/or created by other active 34 * tasks are submitted to the pool from external clients. Especially 40 * most applications. The common pool is used by any ForkJoinTask that 41 * is not explicitly submitted to a specified pool. Using the common 42 * pool normally reduces resource usage (its threads are slowly 49 * The pool attempts to maintain enough active (or available) threads 61 * {@link #toString} returns indications of pool state in a 67 * engaged in fork/join computations in the current pool. The main 71 * tasks that are already executing in a pool shoul 681 newThread(ForkJoinPool pool) argument 690 newThread(ForkJoinPool pool) argument 789 final ForkJoinPool pool; // the containing pool (may be null) field in class:ForkJoinPool.WorkQueue 797 WorkQueue(ForkJoinPool pool, ForkJoinWorkerThread owner) argument 3540 newThread(ForkJoinPool pool) argument [all...] |
/libcore/jsr166-tests/src/test/java/jsr166/ |
H A D | RecursiveActionTest.java | 52 private void testInvokeOnPool(ForkJoinPool pool, RecursiveAction a) { argument 53 try (PoolCleaner cleaner = cleaner(pool)) { 56 assertNull(pool.invoke(a)); 713 * getPool of executing task returns its pool 758 * getPool of current thread in pool returns its pool 772 * getPoolIndex of current thread in pool returns 0 <= value < poolSize 781 // pool size can shrink after assigning index, so cannot check
|
H A D | RecursiveTaskTest.java | 48 private <T> T testInvokeOnPool(ForkJoinPool pool, RecursiveTask<T> a) { argument 49 try (PoolCleaner cleaner = cleaner(pool)) { 52 T result = pool.invoke(a); 551 * getPool of executing task returns its pool
|
H A D | ForkJoinTask8Test.java | 80 private void testInvokeOnPool(ForkJoinPool pool, RecursiveAction a) { argument 81 try (PoolCleaner cleaner = cleaner(pool)) { 89 assertNull(pool.invoke(a)); 388 public void testInvoke(ForkJoinPool pool) { argument 395 testInvokeOnPool(pool, a); 409 public void testQuietlyInvoke(ForkJoinPool pool) { argument 416 testInvokeOnPool(pool, a); 428 public void testForkJoin(ForkJoinPool pool) { argument 436 testInvokeOnPool(pool, a); 448 public void testForkGet(ForkJoinPool pool) { argument 468 testForkTimedGet(ForkJoinPool pool) argument 488 testForkTimedGetNullTimeUnit(ForkJoinPool pool) argument 510 testForkQuietlyJoin(ForkJoinPool pool) argument 531 testForkHelpQuiesce(ForkJoinPool pool) argument 552 testAbnormalInvoke(ForkJoinPool pool) argument 575 testAbnormalQuietlyInvoke(ForkJoinPool pool) argument 595 testAbnormalForkJoin(ForkJoinPool pool) argument 619 testAbnormalForkGet(ForkJoinPool pool) argument 645 testAbnormalForkTimedGet(ForkJoinPool pool) argument 671 testAbnormalForkQuietlyJoin(ForkJoinPool pool) argument 692 testGetPool(ForkJoinPool pool) argument 720 testInForkJoinPool(ForkJoinPool pool) argument 760 testCompleteExceptionally(ForkJoinPool pool) argument 784 testInvokeAll1(ForkJoinPool pool) argument 803 testInvokeAll2(ForkJoinPool pool) argument 826 testInvokeAll3(ForkJoinPool pool) argument 850 testInvokeAllCollection(ForkJoinPool pool) argument 874 testInvokeAllNullTask(ForkJoinPool pool) argument 899 testAbnormalInvokeAll1(ForkJoinPool pool) argument 922 testAbnormalInvokeAll2(ForkJoinPool pool) argument 948 testAbnormalInvokeAll3(ForkJoinPool pool) argument 975 testAbnormalInvokeAllCollection(ForkJoinPool pool) argument [all...] |
H A D | CountedCompleterTest.java | 55 private void testInvokeOnPool(ForkJoinPool pool, ForkJoinTask a) { argument 56 try (PoolCleaner cleaner = cleaner(pool)) { 64 assertNull(pool.invoke(a)); 943 * getPool of executing task returns its pool
|
H A D | ForkJoinTaskTest.java | 57 private void testInvokeOnPool(ForkJoinPool pool, RecursiveAction a) { argument 58 try (PoolCleaner cleaner = cleaner(pool)) { 66 assertNull(pool.invoke(a)); 708 * getPool of executing task returns its pool
|
H A D | JSR166TestCase.java | 695 tearDownFail("ForkJoin common pool thread stuck"); 855 private final ExecutorService pool; field in class:JSR166TestCase.PoolCleaner 856 public PoolCleaner(ExecutorService pool) { this.pool = pool; } argument 857 public void close() { joinPool(pool); } 861 * An extension of PoolCleaner that has an action to release the pool. 865 public PoolCleanerWithReleaser(ExecutorService pool, Runnable releaser) { argument 866 super(pool); 878 PoolCleaner cleaner(ExecutorService pool) { argument 882 cleaner(ExecutorService pool, Runnable releaser) argument 886 cleaner(ExecutorService pool, CountDownLatch latch) argument 897 cleaner(ExecutorService pool, AtomicBoolean flag) argument 908 joinPool(ExecutorService pool) argument [all...] |