| /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
|
| /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...] |
| /httpd/server/mpm/event/ |
| H A D | fdqueue.c | 254 * it reaches into the queue and accesses "next" which can change.
296 #define ap_queue_full(queue) ((queue)->nelts == (queue)->bounds)
302 #define ap_queue_empty(queue) ((queue)->nelts == 0 && APR_RING_EMPTY(&queue->timers ,timer_event_t, link))
310 fd_queue_t *queue = data; local
315 apr_thread_cond_destroy(queue->not_empty);
316 apr_thread_mutex_destroy(queue
324 ap_queue_init(fd_queue_t * queue, int queue_capacity, apr_pool_t * a) argument
363 ap_queue_push(fd_queue_t * queue, apr_socket_t * sd, event_conn_state_t * ecs, apr_pool_t * p) argument
394 ap_queue_push_timer(fd_queue_t * queue, timer_event_t *te) argument
421 ap_queue_pop_something(fd_queue_t * queue, apr_socket_t ** sd, event_conn_state_t ** ecs, apr_pool_t ** p, timer_event_t ** te_out) argument
477 ap_queue_interrupt_all(fd_queue_t * queue) argument
488 ap_queue_term(fd_queue_t * queue) argument
[all...] |
| /httpd/server/mpm/worker/ |
| H A D | fdqueue.c | 191 * it reaches into the queue and accesses "next" which can change.
233 #define ap_queue_full(queue) ((queue)->nelts == (queue)->bounds)
239 #define ap_queue_empty(queue) ((queue)->nelts == 0)
247 fd_queue_t *queue = data; local
252 apr_thread_cond_destroy(queue->not_empty);
253 apr_thread_mutex_destroy(queue->one_big_mutex);
261 apr_status_t ap_queue_init(fd_queue_t *queue, in argument
295 ap_queue_push(fd_queue_t *queue, apr_socket_t *sd, apr_pool_t *p) argument
330 ap_queue_pop(fd_queue_t *queue, apr_socket_t **sd, apr_pool_t **p) argument
375 ap_queue_interrupt_all(fd_queue_t *queue) argument
386 ap_queue_term(fd_queue_t *queue) argument
[all...] |