Searched defs:queue (Results 1 - 5 of 5) sorted by relevance
/glassfish-3.1.2/tests/quicklook/ejb/mdb/src/com/sun/mdb/client/ |
H A D | Client.java | 132 public void sendMsgs(javax.jms.Queue queue, Message msg, int num) argument 135 System.out.println("Sending message " + i + " to " + queue + 137 queueSender.send(queue, msg); 138 System.out.println("Sent message " + i + " to " + queue + 154 System.out.println("Waiting for queue message");
|
/glassfish-3.1.2/persistence/cmp/utility/src/main/java/com/sun/jdo/spi/persistence/utility/ |
H A D | WeakHashSet.java | 56 ReferenceQueue queue = new ReferenceQueue(); field in class:WeakHashSet 114 return super.add(WeakElement.create(o, this.queue)); 148 while ((wv = (WeakElement)this.queue.poll()) != null)
|
H A D | WeakValueHashMap.java | 70 /* Reference queue for cleared WeakValues */ 71 private ReferenceQueue queue = new ReferenceQueue(); field in class:WeakValueHashMap 147 (WeakValue)super.put(key, WeakValue.create(key, value, queue)); 178 while ((wv = (WeakValue) this.queue.poll()) != null) { 212 private WeakValue(Object key, Object value, ReferenceQueue queue) { argument 213 super(value, queue); 218 * Creates a new weak reference and adds it to the given queue. 221 ReferenceQueue queue) { 223 else return new WeakValue(key, value, queue); 288 ent.setValue(WeakValue.create(getKey(), value, queue)); 220 create(Object key, Object value, ReferenceQueue queue) argument [all...] |
/glassfish-3.1.2/connectors/work-management/src/main/java/com/sun/enterprise/connectors/work/ |
H A D | WorkCoordinator.java | 83 private final WorkQueue queue; field in class:WorkCoordinator 106 * @param queue WorkQueue of the threadpool, to which the work 113 WorkQueue queue, 121 this.queue = queue; 138 * Submits the work to the queue and generates a work accepted event. 151 queue.addWork(new OneWork(work, this, contextHandler, Thread.currentThread().getContextClassLoader())); 110 WorkCoordinator(javax.resource.spi.work.Work work, long timeout, ExecutionContext ec, WorkQueue queue, WorkListener listener, WorkManagementProbeProvider probeProvider, ConnectorRuntime runtime, String raName, WorkContextHandler handler) argument
|
/glassfish-3.1.2/core/kernel/src/main/java/com/sun/enterprise/v3/services/impl/monitor/ |
H A D | MonitorableThreadPool.java | 130 Queue<Runnable> queue, 140 queue, 125 GrizzlyIntegrationThreadPoolConfig(String monitoringId, GrizzlyMonitoring monitoring, String poolName, int corePoolSize, int maxPoolSize, Queue<Runnable> queue, int queueLimit, long keepAliveTime, TimeUnit timeUnit, ThreadFactory threadFactory, int priority) argument
|
Completed in 56 milliseconds