/openjdk9/jdk/src/java.naming/share/classes/com/sun/jndi/ldap/pool/ |
H A D | PooledConnection.java | 26 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 D | PoolCallback.java | 26 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 D | PooledConnectionFactory.java | 26 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 D | ConnectionsRef.java | 26 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 D | Stress.java | 28 * 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 D | DelayOverflow.java | 58 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 D | ForkJoinWorkerThread.java | 63 * 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 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...] |
/openjdk9/hotspot/test/serviceability/tmtools/jstat/utils/ |
H A D | Pools.java | 62 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 D | TestPerfCountersAndMemoryPools.java | 53 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 D | ModifyCorePoolSize.java | 27 * @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 D | TimeOutShrink.java | 43 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 D | ShutdownNowExecuteRace.java | 43 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 D | resolutionErrors.cpp | 35 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 D | resolutionErrors.hpp | 34 // 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 D | ByteBufferReference.java | 36 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 D | ByteBufferPool.java | 40 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 D | PooledSjavac.java | 49 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 D | Basic.java | 56 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 D | lowMemoryDetector.cpp | 46 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 D | lowMemoryDetector.hpp | 37 // 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 D | HeapRegionUsageTool.java | 40 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 D | Klass.java | 24 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 D | KlassDup.java | 24 package compiler.compilercontrol.share.pool.sub; 26 import compiler.compilercontrol.share.pool.MethodHolder;
|
/openjdk9/jdk/test/java/nio/file/WatchService/ |
H A D | LotsOfCloses.java | 51 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));
|