Searched defs:pool (Results 26 - 50 of 97) sorted by relevance

1234

/openjdk7/jdk/test/java/util/concurrent/BlockingQueue/
H A DCancelledProducerConsumerLoops.java50 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 DSingleProducerMultipleConsumerLoops.java47 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 DMultipleProducersSingleConsumerLoops.java46 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 DProducerConsumerLoops.java47 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 DExchangeLoops.java45 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 DModifyCorePoolSize.java27 * @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 DShutdownNowExecuteRace.java41 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 DTimeOutShrink.java35 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 DLockOncePerThreadLoops.java47 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 DTimeoutLockLoops.java50 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 DMapLoops.java60 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 DMemoryPoolImpl.c32 (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 DConnectionDesc.java26 package com.sun.jndi.ldap.pool;
H A DPool.java26 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 DConnections.java26 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 DB6373555.java48 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 DPool.java32 /** 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 DMapLoops.java60 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 DDelayOverflow.java48 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 DPort.java61 Port(AsynchronousChannelProvider provider, ThreadPool pool) { argument
62 super(provider, pool);
/openjdk7/hotspot/src/share/vm/oops/
H A DcpCacheKlass.cpp94 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 DlowMemoryDetector.cpp45 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 DmemoryManager.cpp51 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 DXMLStreamWriterFactory.java245 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 DWindowsChannelFactory.java170 * @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

Completed in 267 milliseconds

1234