/openjdk7/jdk/test/java/util/concurrent/BlockingQueue/ |
H A D | CancelledProducerConsumerLoops.java | 50 static final ExecutorService pool = Executors.newCachedThreadPool(); field in class:CancelledProducerConsumerLoops 72 pool.shutdown(); 73 if (! pool.awaitTermination(Long.MAX_VALUE, TimeUnit.NANOSECONDS)) 86 prods[i] = pool.submit(new Producer(q, barrier, iters)); 87 cons[i] = pool.submit(new Consumer(q, barrier, iters));
|
H A D | SingleProducerMultipleConsumerLoops.java | 47 static final ExecutorService pool = Executors.newCachedThreadPool(); field in class:SingleProducerMultipleConsumerLoops 71 pool.shutdown(); 72 if (! pool.awaitTermination(Long.MAX_VALUE, TimeUnit.NANOSECONDS)) 158 pool.execute(new Producer(q, barrier, iters * nconsumers)); 160 pool.execute(new Consumer(q, barrier, iters));
|
H A D | MultipleProducersSingleConsumerLoops.java | 46 static final ExecutorService pool = Executors.newCachedThreadPool(); field in class:MultipleProducersSingleConsumerLoops 85 pool.shutdown(); 86 if (! pool.awaitTermination(Long.MAX_VALUE, TimeUnit.NANOSECONDS)) 174 pool.execute(new Producer(q, barrier, iters)); 176 pool.execute(new Consumer(q, barrier, iters * nproducers));
|
H A D | ProducerConsumerLoops.java | 47 static final ExecutorService pool = Executors.newCachedThreadPool(); field in class:ProducerConsumerLoops 85 pool.shutdown(); 86 if (! pool.awaitTermination(Long.MAX_VALUE, TimeUnit.NANOSECONDS)) 172 pool.execute(new Producer(q, barrier, iters)); 173 pool.execute(new Consumer(q, barrier, iters));
|
/openjdk7/jdk/test/java/util/concurrent/Exchanger/ |
H A D | ExchangeLoops.java | 45 static final ExecutorService pool = Executors.newCachedThreadPool(); field in class:ExchangeLoops 70 pool.shutdown(); 71 if (! pool.awaitTermination(Long.MAX_VALUE, TimeUnit.NANOSECONDS)) 127 pool.execute(new Stage(l, r, barrier, iters));
|
/openjdk7/jdk/test/java/util/concurrent/ThreadPoolExecutor/ |
H A D | ModifyCorePoolSize.java | 27 * @summary Test changes to STPE core pool size 34 static void awaitPoolSize(ThreadPoolExecutor pool, int n) { argument 35 while (pool.getPoolSize() != n) Thread.yield(); 39 static void setCorePoolSize(ThreadPoolExecutor pool, int n) { argument 40 pool.setCorePoolSize(n); 41 equal(pool.getCorePoolSize(), n); 42 awaitPoolSize(pool, n); 47 final ScheduledThreadPoolExecutor pool 52 pool.scheduleAtFixedRate(nop, 100L * (i + 1), 54 awaitPoolSize(pool, siz [all...] |
H A D | ShutdownNowExecuteRace.java | 41 static volatile ThreadPoolExecutor pool = null; field in class:ShutdownNowExecuteRace 53 ThreadPoolExecutor pool = ShutdownNowExecuteRace.pool; 54 if (pool != null) 55 try { pool.execute(sleeper); } 60 pool = new ThreadPoolExecutor( 63 pool.shutdownNow(); 64 check(pool.awaitTermination(3L, TimeUnit.MINUTES));
|
H A D | TimeOutShrink.java | 35 static void checkPoolSizes(ThreadPoolExecutor pool, argument 37 equal(pool.getPoolSize(), size); 38 equal(pool.getCorePoolSize(), core); 39 equal(pool.getMaximumPoolSize(), max); 45 final ThreadPoolExecutor pool 55 pool.execute(r); 57 checkPoolSizes(pool, 2*n, n, 2*n); 59 while (pool.getPoolSize() > n) 62 checkPoolSizes(pool, n, n, 2*n); 63 pool [all...] |
/openjdk7/jdk/test/java/util/concurrent/locks/ReentrantLock/ |
H A D | LockOncePerThreadLoops.java | 47 static final ExecutorService pool = Executors.newCachedThreadPool(); field in class:LockOncePerThreadLoops 68 pool.shutdown(); 69 if (! pool.awaitTermination(Long.MAX_VALUE, TimeUnit.NANOSECONDS)) 89 pool.execute(this);
|
H A D | TimeoutLockLoops.java | 50 static final ExecutorService pool = Executors.newCachedThreadPool(); field in class:TimeoutLockLoops 69 pool.shutdown(); 70 if (! pool.awaitTermination(Long.MAX_VALUE, TimeUnit.NANOSECONDS)) 90 pool.execute(this);
|
/openjdk7/jdk/test/java/util/concurrent/locks/ReentrantReadWriteLock/ |
H A D | MapLoops.java | 60 static final ExecutorService pool = Executors.newCachedThreadPool(); field in class:MapLoops 115 pool.execute(new Runner(map, key, barrier)); 125 pool.shutdown(); 126 if (! pool.awaitTermination(Long.MAX_VALUE, TimeUnit.NANOSECONDS))
|
/openjdk7/jdk/src/share/native/sun/management/ |
H A D | MemoryPoolImpl.c | 32 (JNIEnv *env, jobject pool) 34 jobject mgrs = jmm_interface->GetMemoryManagers(env, pool); 37 // pool will never become invalid. 45 (JNIEnv *env, jobject pool) 47 jobject usage = jmm_interface->GetMemoryPoolUsage(env, pool); 50 // pool will never become invalid. 58 (JNIEnv *env, jobject pool) 60 jobject usage = jmm_interface->GetPeakMemoryPoolUsage(env, pool); 63 // pool will never become invalid. 71 (JNIEnv *env, jobject pool, jlon 31 Java_sun_management_MemoryPoolImpl_getMemoryManagers0(JNIEnv *env, jobject pool) argument 44 Java_sun_management_MemoryPoolImpl_getUsage0(JNIEnv *env, jobject pool) argument 57 Java_sun_management_MemoryPoolImpl_getPeakUsage0(JNIEnv *env, jobject pool) argument 70 Java_sun_management_MemoryPoolImpl_setUsageThreshold0(JNIEnv *env, jobject pool, jlong current, jlong newThreshold) argument 90 Java_sun_management_MemoryPoolImpl_setCollectionThreshold0(JNIEnv *env, jobject pool, jlong current, jlong newThreshold) argument 114 Java_sun_management_MemoryPoolImpl_resetPeakUsage0(JNIEnv *env, jobject pool) argument 123 Java_sun_management_MemoryPoolImpl_setPoolUsageSensor(JNIEnv *env, jobject pool, jobject sensor) argument 131 Java_sun_management_MemoryPoolImpl_setPoolCollectionSensor(JNIEnv *env, jobject pool, jobject sensor) argument 139 Java_sun_management_MemoryPoolImpl_getCollectionUsage0(JNIEnv *env, jobject pool) argument [all...] |
/openjdk7/jdk/src/share/classes/com/sun/jndi/ldap/pool/ |
H A D | ConnectionDesc.java | 26 package com.sun.jndi.ldap.pool;
|
H A D | Pool.java | 26 package com.sun.jndi.ldap.pool; 42 * A map of pool ids to Connections. 52 * - retrieves (or creates as necessary) a connection from the pool 53 * - removes expired connections from the pool 56 * A WeakHashMap is used for mapping the pool ids and Connections. 90 final private int maxSize; // max num of identical conn per pool 91 final private int prefSize; // preferred num of identical conn per pool 158 * and then removed from the pool (removePooledConnection() will eventually 210 out.println("maximum pool size: " + maxSize); 211 out.println("preferred pool siz [all...] |
H A D | Connections.java | 26 package com.sun.jndi.ldap.pool; 41 * same pool id. 82 * @param prefSize the preferred size of the pool. The pool will try 83 * to maintain a pool of this size by creating and closing connections 85 * @param maxSize the maximum size of the pool. The pool will not exceed 86 * this size. If the pool is at this size, a request for a connection 87 * will block until an idle connection is released to the pool or 117 conns.add(new ConnectionDesc(conn)); // Add new idle conn to pool [all...] |
/openjdk7/jdk/test/com/sun/net/httpserver/bugs/ |
H A D | B6373555.java | 48 static ExecutorService pool, execs; field in class:B6373555 60 pool = Executors.newFixedThreadPool(10); 63 pool.execute(new Client()); 69 pool.shutdown(); 72 if (pool.awaitTermination(2000L, TimeUnit.MILLISECONDS)) { 83 pool.shutdownNow();
|
/openjdk7/langtools/src/share/classes/com/sun/tools/javac/jvm/ |
H A D | Pool.java | 32 /** An internal structure that corresponds to the constant pool of a classfile. 48 /** The initial pool buffer. 50 Object[] pool; field in class:Pool 52 /** A hashtable containing all constants in the pool. 56 /** Construct a pool with given number of elements and element array. 58 public Pool(int pp, Object[] pool) { argument 60 this.pool = pool; 61 this.indices = new HashMap<Object,Integer>(pool.length); 63 if (pool[ [all...] |
/openjdk7/jdk/test/java/util/concurrent/ConcurrentHashMap/ |
H A D | MapLoops.java | 60 static final ExecutorService pool = Executors.newCachedThreadPool(); field in class:MapLoops 123 pool.shutdown(); 124 if (! pool.awaitTermination(Long.MAX_VALUE, TimeUnit.NANOSECONDS)) 160 pool.execute(new Runner(map, key, barrier));
|
/openjdk7/jdk/test/java/util/concurrent/ScheduledThreadPoolExecutor/ |
H A D | DelayOverflow.java | 48 void scheduleNow(ScheduledThreadPoolExecutor pool, argument 52 pool.schedule(r, 0, TimeUnit.MILLISECONDS); 55 pool.schedule(Executors.callable(r), 0, TimeUnit.DAYS); 58 pool.scheduleWithFixedDelay(r, 0, 1000, TimeUnit.NANOSECONDS); 61 pool.scheduleAtFixedRate(r, 0, 1000, TimeUnit.MILLISECONDS); 68 void scheduleAtTheEndOfTime(ScheduledThreadPoolExecutor pool, argument 72 pool.schedule(r, Long.MAX_VALUE, TimeUnit.MILLISECONDS); 75 pool.schedule(Executors.callable(r), Long.MAX_VALUE, TimeUnit.DAYS); 78 pool.scheduleWithFixedDelay(r, Long.MAX_VALUE, 1000, TimeUnit.NANOSECONDS); 81 pool [all...] |
/openjdk7/jdk/src/solaris/classes/sun/nio/ch/ |
H A D | Port.java | 61 Port(AsynchronousChannelProvider provider, ThreadPool pool) { argument 62 super(provider, pool);
|
/openjdk7/hotspot/src/share/vm/oops/ |
H A D | cpCacheKlass.cpp | 94 assert(obj->is_constantPoolCache(), "obj must be constant pool cache"); 98 // gc of constant pool cache instance variables 100 // gc of constant pool cache entries 108 assert(obj->is_constantPoolCache(), "obj must be constant pool cache"); 112 // gc of constant pool cache instance variables 114 // gc of constant pool cache entries 122 assert(obj->is_constantPoolCache(), "obj must be constant pool cache"); 129 // iteration over constant pool cache instance variables 131 // iteration over constant pool cache entries 138 assert(obj->is_constantPoolCache(), "obj must be constant pool cach 176 constantPoolOop pool = cache->constant_pool(); local [all...] |
/openjdk7/hotspot/src/share/vm/services/ |
H A D | lowMemoryDetector.cpp | 45 MemoryPool* pool = MemoryService::get_memory_pool(i); local 46 SensorInfo* sensor = pool->usage_sensor(); 51 SensorInfo* gc_sensor = pool->gc_usage_sensor(); 66 MemoryPool* pool = MemoryService::get_memory_pool(i); local 67 SensorInfo* sensor = pool->usage_sensor(); 68 SensorInfo* gc_sensor = pool->gc_usage_sensor(); 86 MemoryPool* pool = MemoryService::get_memory_pool(i); local 87 SensorInfo* sensor = pool->usage_sensor(); 89 pool->usage_threshold()->is_high_threshold_supported() && 90 pool 105 detect_low_memory(MemoryPool* pool) argument 127 detect_after_gc_memory(MemoryPool* pool) argument 153 MemoryPool* pool = MemoryService::get_memory_pool(i); local [all...] |
H A D | memoryManager.cpp | 51 void MemoryManager::add_pool(MemoryPool* pool) { argument 54 _pools[_num_pools] = pool; 57 pool->add_manager(this); 238 MemoryPool* pool = MemoryService::get_memory_pool(i); local 239 MemoryUsage usage = pool->get_memory_usage(); 244 pool->name(), strlen(pool->name()), 250 (char *) pool->name(), strlen(pool->name()), 276 MemoryPool* pool local 298 MemoryPool* pool = get_memory_pool(i); local [all...] |
/openjdk7/jaxws/src/share/jaxws_classes/com/sun/xml/internal/ws/api/streaming/ |
H A D | XMLStreamWriterFactory.java | 245 private final ThreadLocal<XMLStreamWriter> pool = new ThreadLocal<XMLStreamWriter>(); field in class:XMLStreamWriterFactory.Zephyr 274 * Fetchs an instance from the pool if available, otherwise null. 277 XMLStreamWriter sr = pool.get(); 279 pool.set(null); 318 pool.set(r);
|
/openjdk7/jdk/src/windows/classes/sun/nio/fs/ |
H A D | WindowsChannelFactory.java | 170 * @param pool 171 * The thread pool that the channel is associated with 177 ThreadPool pool) 205 return WindowsAsynchronousFileChannelImpl.open(fdObj, flags.read, flags.write, pool); 173 newAsynchronousFileChannel(String pathForWindows, String pathToCheck, Set<? extends OpenOption> options, long pSecurityDescriptor, ThreadPool pool) argument
|