Searched refs:pool (Results 1 - 25 of 230) sorted by relevance

12345678910

/openjdk9/jdk/src/java.naming/share/classes/com/sun/jndi/ldap/pool/
H A DPooledConnection.java26 package com.sun.jndi.ldap.pool;
29 * Represents a connection that is managed in a pool. The connection
34 * method would interact with the connection pool to return the connection
35 * to the pool (see PoolCallback).
38 * connection pool can use to physically close the connection.
39 * The pool might need to physically close the connection as determined
40 * by the pool's policy (for example, to manage the pool size or idle
H A DPoolCallback.java26 package com.sun.jndi.ldap.pool;
30 * into the pool.
35 * interact with the connection pool to return the connection
36 * to the pool.
40 * pool manager.
46 * Releases a useable connection back to the pool.
50 * is no longer in the pool.
55 * Removes a connection from the pool. The connection should not be reused.
60 * is no longer in the pool prior to removal.
H A DPooledConnectionFactory.java26 package com.sun.jndi.ldap.pool;
32 * The user of the connection pool should provide an implementation of this
43 * connection from the pool.
H A DConnectionsRef.java26 package com.sun.jndi.ldap.pool;
33 * <-> com.sun.jndi.ldap.pool.Connections
46 * when they are returned to the pool.
/openjdk9/jdk/test/java/util/concurrent/ScheduledThreadPoolExecutor/
H A DStress.java28 * 6602600: Fast removal of cancelled scheduled thread pool tasks
39 final ScheduledThreadPoolExecutor pool =
41 pool.prestartAllCoreThreads();
47 pool.scheduleAtFixedRate(incTask, 0, 10, TimeUnit.MILLISECONDS);
51 pool.shutdown();
52 pool.awaitTermination(1L, TimeUnit.DAYS);
H A DDelayOverflow.java58 void scheduleNow(ScheduledThreadPoolExecutor pool, argument
62 pool.schedule(r, 0, MILLISECONDS);
65 pool.schedule(Executors.callable(r), 0, DAYS);
68 pool.scheduleWithFixedDelay(r, 0, 1000, NANOSECONDS);
71 pool.scheduleAtFixedRate(r, 0, 1000, MILLISECONDS);
78 void scheduleAtTheEndOfTime(ScheduledThreadPoolExecutor pool, argument
82 pool.schedule(r, Long.MAX_VALUE, MILLISECONDS);
85 pool.schedule(Executors.callable(r), Long.MAX_VALUE, DAYS);
88 pool.scheduleWithFixedDelay(r, Long.MAX_VALUE, 1000, NANOSECONDS);
91 pool
[all...]
/openjdk9/jdk/src/java.base/share/classes/java/util/concurrent/
H A DForkJoinWorkerThread.java63 * This class just maintains links to its pool and WorkQueue. The
64 * pool field is set immediately upon construction, but the
76 final ForkJoinPool pool; // the pool this thread works in field in class:ForkJoinWorkerThread
80 * Creates a ForkJoinWorkerThread operating in the given pool.
82 * @param pool the pool this thread works in
83 * @throws NullPointerException if pool is null
85 protected ForkJoinWorkerThread(ForkJoinPool pool) { argument
88 this.pool
97 ForkJoinWorkerThread(ForkJoinPool pool, ClassLoader ccl) argument
107 ForkJoinWorkerThread(ForkJoinPool pool, ClassLoader ccl, ThreadGroup threadGroup, AccessControlContext acc) argument
222 InnocuousForkJoinWorkerThread(ForkJoinPool pool) argument
[all...]
/openjdk9/jdk/src/java.management/share/native/libmanagement/
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...]
/openjdk9/hotspot/test/serviceability/tmtools/jstat/utils/
H A DPools.java62 MemoryPoolMXBean pool = findPool(poolName);
63 if (pool != null) {
64 if (pool.getUsage().getMax() == -1) {
67 result = pool.getUsage().getCommitted() / 1024;
72 log("Max size of the pool '" + poolName + "' is " + result);
78 MemoryPoolMXBean pool = findPool(poolName);
79 if (pool != null) {
80 if (pool.getUsage().getCommitted() == -1) {
83 result = pool.getUsage().getCommitted() / 1024;
88 log("Committed size of the pool '"
[all...]
/openjdk9/hotspot/test/gc/metaspace/
H A DTestPerfCountersAndMemoryPools.java53 for (MemoryPoolMXBean pool : pools) {
54 if (pool.getName().equals(memoryPoolName)) {
55 return pool;
59 throw new RuntimeException("Excpted to find a memory pool with name " +
65 MemoryPoolMXBean pool = getMemoryPool(memoryPoolName);
71 pool.getUsage().getInit();
72 pool.getUsage().getUsed();
73 pool.getUsage().getCommitted();
78 assertEQ(getMinCapacity(perfNS), pool.getUsage().getInit(), "MinCapacity out of sync");
81 // initial size from the pool
[all...]
/openjdk9/jdk/test/java/util/concurrent/ThreadPoolExecutor/
H A DModifyCorePoolSize.java27 * @summary Test changes to STPE core pool size
36 static void awaitPoolSize(ThreadPoolExecutor pool, int n) { argument
37 while (pool.getPoolSize() != n) Thread.yield();
41 static void setCorePoolSize(ThreadPoolExecutor pool, int n) { argument
42 pool.setCorePoolSize(n);
43 equal(pool.getCorePoolSize(), n);
44 awaitPoolSize(pool, n);
49 final ScheduledThreadPoolExecutor pool
54 pool.scheduleAtFixedRate(nop, 100L * (i + 1),
56 awaitPoolSize(pool, siz
[all...]
H A DTimeOutShrink.java43 static void checkPoolSizes(ThreadPoolExecutor pool, argument
45 equal(pool.getPoolSize(), size);
46 equal(pool.getCorePoolSize(), core);
47 equal(pool.getMaximumPoolSize(), max);
53 final ThreadPoolExecutor pool
64 pool.execute(r);
66 checkPoolSizes(pool, 2*n, n, 2*n);
69 for (long sleepyTime = 0L; pool.getPoolSize() > n; ) {
73 checkPoolSizes(pool, n, n, 2*n);
75 checkPoolSizes(pool,
[all...]
H A DShutdownNowExecuteRace.java43 static volatile ThreadPoolExecutor pool = null; field in class:ShutdownNowExecuteRace
55 ThreadPoolExecutor pool = ShutdownNowExecuteRace.pool;
56 if (pool != null)
57 try { pool.execute(sleeper); }
62 pool = new ThreadPoolExecutor(
65 pool.shutdownNow();
66 check(pool.awaitTermination(3L, TimeUnit.MINUTES));
/openjdk9/hotspot/src/share/vm/classfile/
H A DresolutionErrors.cpp35 const constantPoolHandle& pool, int cp_index,
39 assert(!pool.is_null() && error != NULL, "adding NULL obj");
41 ResolutionErrorEntry* entry = new_entry(hash, pool(), cp_index, error, message);
47 const constantPoolHandle& pool, int cp_index)
54 if (error_probe->hash() == hash && error_probe->pool() == pool()) {
74 ResolutionErrorEntry* ResolutionErrorTable::new_entry(int hash, ConstantPool* pool, argument
78 ResolutionErrorEntry* entry = (ResolutionErrorEntry*)Hashtable<ConstantPool*, mtClass>::new_entry(hash, pool);
101 // constant pool that is going away
107 assert(entry->pool() !
34 add_entry(int index, unsigned int hash, const constantPoolHandle& pool, int cp_index, Symbol* error, Symbol* message) argument
46 find_entry(int index, unsigned int hash, const constantPoolHandle& pool, int cp_index) argument
126 ConstantPool* pool = entry->pool(); local
[all...]
H A DresolutionErrors.hpp34 // constant pool resolution (JVMS 5.4.3).
41 ResolutionErrorEntry* new_entry(int hash, ConstantPool* pool, int cp_index,
59 const constantPoolHandle& pool, int which, Symbol* error, Symbol* message);
62 // find error given the constant pool and constant pool index
64 const constantPoolHandle& pool, int cp_index);
67 unsigned int compute_hash(const constantPoolHandle& pool, int cp_index) { argument
68 return (unsigned int) pool->identity_hash() + cp_index;
74 // RedefineClasses support - remove obsolete constant pool entry
86 ConstantPool* pool() cons function in class:ResolutionErrorEntry
[all...]
/openjdk9/jdk/src/jdk.incubator.httpclient/share/classes/jdk/incubator/http/internal/common/
H A DByteBufferReference.java36 private final ByteBufferPool pool; field in class:ByteBufferReference
42 public static ByteBufferReference of(ByteBuffer buffer, ByteBufferPool pool) { argument
44 return new ByteBufferReference(buffer, pool);
70 private ByteBufferReference(ByteBuffer buffer, ByteBufferPool pool) { argument
72 this.pool = pool;
86 if (pool != null) {
87 pool.release(buf);
H A DByteBufferPool.java40 private final java.util.Queue<ByteBuffer> pool = new ConcurrentLinkedQueue<>(); field in class:ByteBufferPool
47 while ((buffer = pool.poll()) != null) {
57 pool.offer(buffer);
/openjdk9/langtools/src/jdk.compiler/share/classes/com/sun/tools/sjavac/comp/
H A DPooledSjavac.java49 final ExecutorService pool; field in class:PooledSjavac
54 pool = Executors.newFixedThreadPool(poolsize);
61 return pool.submit(() -> {
74 pool.shutdown(); // Disable new tasks from being submitted
77 if (!pool.awaitTermination(60, TimeUnit.SECONDS)) {
78 pool.shutdownNow(); // Cancel currently executing tasks
80 if (!pool.awaitTermination(60, TimeUnit.SECONDS))
85 pool.shutdownNow();
/openjdk9/jdk/test/java/nio/channels/AsynchronousChannelGroup/
H A DBasic.java56 static void testShutdownWithNoChannels(ExecutorService pool, argument
65 if (pool != null && !pool.isTerminated())
69 static void testShutdownWithChannels(ExecutorService pool, argument
90 if (pool != null && !pool.isTerminated())
99 ExecutorService pool = Executors.newCachedThreadPool();
101 .withCachedThreadPool(pool, rand.nextInt(5));
102 testShutdownWithNoChannels(pool, group);
111 ExecutorService pool
150 testShutdownNow(ExecutorService pool, AsynchronousChannelGroup group) argument
[all...]
/openjdk9/hotspot/src/share/vm/services/
H A DlowMemoryDetector.cpp46 MemoryPool* pool = MemoryService::get_memory_pool(i); local
47 SensorInfo* sensor = pool->usage_sensor();
52 SensorInfo* gc_sensor = pool->gc_usage_sensor();
67 MemoryPool* pool = MemoryService::get_memory_pool(i); local
68 SensorInfo* sensor = pool->usage_sensor();
69 SensorInfo* gc_sensor = pool->gc_usage_sensor();
87 MemoryPool* pool = MemoryService::get_memory_pool(i); local
88 SensorInfo* sensor = pool->usage_sensor();
90 pool->usage_threshold()->is_high_threshold_supported() &&
91 pool
106 detect_low_memory(MemoryPool* pool) argument
128 detect_after_gc_memory(MemoryPool* pool) argument
154 MemoryPool* pool = MemoryService::get_memory_pool(i); local
[all...]
H A DlowMemoryDetector.hpp37 // When the VM detects if the memory usage of a memory pool has reached
39 // of the memory pool (heap or nonheap or both).
44 // that memory pool. The threshold can be set to any non-negative
232 static void detect_low_memory(MemoryPool* pool);
233 static void detect_after_gc_memory(MemoryPool* pool);
235 static bool is_enabled(MemoryPool* pool) { argument
237 // iff one of the collected memory pool has a sensor and the
239 if (pool->usage_sensor() == NULL) {
242 ThresholdSupport* threshold_support = pool->usage_threshold();
265 MemoryPool* pool local
[all...]
/openjdk9/hotspot/test/gc/arguments/
H A DHeapRegionUsageTool.java40 for (MemoryPoolMXBean pool : ManagementFactory.getMemoryPoolMXBeans()) {
41 if (pool.getName().matches(name)) {
42 return pool.getUsage();
/openjdk9/hotspot/test/compiler/compilercontrol/share/pool/subpack/
H A DKlass.java24 package compiler.compilercontrol.share.pool.subpack;
26 import compiler.compilercontrol.share.pool.MethodHolder;
30 * This is a clone of the c.c.s.pool.sub.Klass, but without inner class
32 * *Klass patern should match both c.c.s.pool.sub.Klass and c.c.s.pool.subpack.Klass
/openjdk9/hotspot/test/compiler/compilercontrol/share/pool/sub/
H A DKlassDup.java24 package compiler.compilercontrol.share.pool.sub;
26 import compiler.compilercontrol.share.pool.MethodHolder;
/openjdk9/jdk/test/java/nio/file/WatchService/
H A DLotsOfCloses.java51 ExecutorService pool = Executors.newCachedThreadPool();
57 test(dir, pool);
61 pool.shutdown();
71 static void test(Path dir, ExecutorService pool) throws Exception { argument
82 closeResult = pool.submit(newCloserTask(watcher));
83 registerResult = pool.submit(newRegisterTask(watcher, dir));
85 registerResult = pool.submit(newRegisterTask(watcher, dir));
86 closeResult = pool.submit(newCloserTask(watcher));

Completed in 129 milliseconds

12345678910