Searched refs:queue (Results 1 - 25 of 194) sorted by relevance

12345678

/forgerock/openam-v13/openam-shared/src/test/java/org/forgerock/openam/shared/concurrency/
H A DResizableLinkedBlockingQueueTest.java27 ResizableLinkedBlockingQueue<Object> queue = new ResizableLinkedBlockingQueue<>(10);
29 queue.resizeQueue(6);
31 int queueSize = queue.getMaximumQueueSize();
37 ResizableLinkedBlockingQueue<Object> queue = new ResizableLinkedBlockingQueue<>(10);
39 queue.resizeQueue(14);
41 int queueSize = queue.getMaximumQueueSize();
/forgerock/openam/openam-shared/src/test/java/org/forgerock/openam/shared/concurrency/
H A DResizableLinkedBlockingQueueTest.java27 ResizableLinkedBlockingQueue<Object> queue = new ResizableLinkedBlockingQueue<>(10);
29 queue.resizeQueue(6);
31 int queueSize = queue.getMaximumQueueSize();
37 ResizableLinkedBlockingQueue<Object> queue = new ResizableLinkedBlockingQueue<>(10);
39 queue.resizeQueue(14);
41 int queueSize = queue.getMaximumQueueSize();
/forgerock/openam-v13/openam-core/src/main/java/org/forgerock/openam/cts/impl/queue/config/
H A Dpackage-info.java21 package org.forgerock.openam.cts.impl.queue.config;
/forgerock/openam-v13/openam-core/src/main/java/org/forgerock/openam/cts/impl/queue/
H A Dpackage-info.java18 * Classes responsible for managing the asynchronous task queue which is used by the CTS to
23 package org.forgerock.openam.cts.impl.queue;
H A DQueueSelector.java16 package org.forgerock.openam.cts.impl.queue;
21 * QueueSelector is responsible for selecting an appropriate asynchronous queue for
25 * are processed by the same queue. By enforcing this invariant, we can be certain that
/forgerock/openam/openam-core/src/main/java/org/forgerock/openam/cts/impl/queue/config/
H A Dpackage-info.java21 package org.forgerock.openam.cts.impl.queue.config;
/forgerock/openam/openam-core/src/main/java/org/forgerock/openam/cts/impl/queue/
H A Dpackage-info.java18 * Classes responsible for managing the asynchronous task queue which is used by the CTS to
23 package org.forgerock.openam.cts.impl.queue;
H A DQueueSelector.java16 package org.forgerock.openam.cts.impl.queue;
21 * QueueSelector is responsible for selecting an appropriate asynchronous queue for
25 * are processed by the same queue. By enforcing this invariant, we can be certain that
/forgerock/openam-v13/openam-shared/src/main/java/com/sun/identity/shared/
H A DBufferedIterator.java44 private final BlockingQueue<T> queue = new LinkedBlockingQueue<T>(); field in class:BufferedIterator
48 queue.add(entry);
52 queue.addAll(entry);
62 return queue.take();
71 return !(done && queue.isEmpty());
/forgerock/openam/openam-shared/src/main/java/com/sun/identity/shared/
H A DBufferedIterator.java44 private final BlockingQueue<T> queue = new LinkedBlockingQueue<T>(); field in class:BufferedIterator
48 queue.add(entry);
52 queue.addAll(entry);
62 return queue.take();
71 return !(done && queue.isEmpty());
/forgerock/openam-v13/openam-core/src/test/java/org/forgerock/openam/cts/impl/queue/
H A DTaskDispatcherTest.java16 package org.forgerock.openam.cts.impl.queue;
34 private TaskDispatcher queue; field in class:TaskDispatcherTest
49 queue = new TaskDispatcher(
56 queue.startDispatcher();
62 queue.create(null, mockHandler);
67 queue.update(null, mockHandler);
72 queue.delete(null, mockHandler);
77 queue.read(null, null);
82 queue.query(null, null);
87 queue
[all...]
/forgerock/openam-v13/openam-core/src/main/java/org/forgerock/openam/cts/reaper/
H A DTokenDeletion.java20 import org.forgerock.openam.cts.impl.queue.TaskDispatcher;
34 private final TaskDispatcher queue; field in class:TokenDeletion
37 public TokenDeletion(TaskDispatcher queue) { argument
38 this.queue = queue;
57 queue.delete(token, handler);
/forgerock/opendj-b2.6/src/server/org/opends/server/loggers/
H A DAsynchronousTextWriter.java57 private final LinkedBlockingQueue<String> queue; field in class:AsynchronousTextWriter
59 /** The capacity for the queue. */
72 * @param capacity the size of the queue before it gets flushed.
74 * after the queue is flushed.
84 this.queue = new LinkedBlockingQueue<String>(capacity);
96 * The publisher thread is responsible for emptying the queue of log records
106 * the run method of the writerThread. Run until queue is empty
114 while (!stopRequested.get() || !queue.isEmpty()) {
117 queue.drainTo(drainList, capacity);
120 message = queue
[all...]
H A DParallelTextWriter.java46 * parallel unbound ie there is no queue size cap imposed.
57 private final ConcurrentLinkedQueue<String> queue; field in class:ParallelTextWriter
72 * after the queue is flushed.
81 this.queue = new ConcurrentLinkedQueue<String>();
92 * The publisher thread is responsible for emptying the queue of log records
102 * the run method of the writerThread. Run until queue is empty
116 String message = queue.poll();
152 // Put request on queue for writer
153 queue.add(record);
234 // The writer writerThread SHOULD have drained the queue
[all...]
/forgerock/opendj2/src/server/org/opends/server/loggers/
H A DAsynchronousTextWriter.java52 private final LinkedBlockingQueue<String> queue; field in class:AsynchronousTextWriter
54 /** The capacity for the queue. */
67 * @param capacity the size of the queue before it gets flushed.
69 * after the queue is flushed.
79 this.queue = new LinkedBlockingQueue<String>(capacity);
91 * The publisher thread is responsible for emptying the queue of log records
102 * the run method of the writerThread. Run until queue is empty
111 while (!stopRequested.get() || !queue.isEmpty()) {
114 queue.drainTo(drainList, capacity);
117 message = queue
[all...]
/forgerock/opendj2.6.2/src/server/org/opends/server/loggers/
H A DAsynchronousTextWriter.java57 private final LinkedBlockingQueue<String> queue; field in class:AsynchronousTextWriter
59 /** The capacity for the queue. */
72 * @param capacity the size of the queue before it gets flushed.
74 * after the queue is flushed.
84 this.queue = new LinkedBlockingQueue<String>(capacity);
96 * The publisher thread is responsible for emptying the queue of log records
106 * the run method of the writerThread. Run until queue is empty
114 while (!stopRequested.get() || !queue.isEmpty()) {
117 queue.drainTo(drainList, capacity);
120 message = queue
[all...]
/forgerock/opendj2-jel-hg/src/server/org/opends/server/loggers/
H A DAsynchronousTextWriter.java57 private final LinkedBlockingQueue<String> queue; field in class:AsynchronousTextWriter
59 /** The capacity for the queue. */
72 * @param capacity the size of the queue before it gets flushed.
74 * after the queue is flushed.
84 this.queue = new LinkedBlockingQueue<String>(capacity);
96 * The publisher thread is responsible for emptying the queue of log records
106 * the run method of the writerThread. Run until queue is empty
114 while (!stopRequested.get() || !queue.isEmpty()) {
117 queue.drainTo(drainList, capacity);
120 message = queue
[all...]
/forgerock/opendj2-hg/src/server/org/opends/server/loggers/
H A DAsynchronousTextWriter.java52 private final LinkedBlockingQueue<String> queue; field in class:AsynchronousTextWriter
54 /** The capacity for the queue. */
67 * @param capacity the size of the queue before it gets flushed.
69 * after the queue is flushed.
79 this.queue = new LinkedBlockingQueue<String>(capacity);
91 * The publisher thread is responsible for emptying the queue of log records
102 * the run method of the writerThread. Run until queue is empty
111 while (!stopRequested.get() || !queue.isEmpty()) {
114 queue.drainTo(drainList, capacity);
117 message = queue
[all...]
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/loggers/
H A DAsynchronousTextWriter.java52 private final LinkedBlockingQueue<String> queue; field in class:AsynchronousTextWriter
54 /** The capacity for the queue. */
67 * @param capacity the size of the queue before it gets flushed.
69 * after the queue is flushed.
79 this.queue = new LinkedBlockingQueue<>(capacity);
91 * The publisher thread is responsible for emptying the queue of log records
102 * The run method of the writerThread. Run until queue is empty
111 while (!stopRequested.get() || !queue.isEmpty()) {
114 queue.drainTo(drainList, capacity);
117 message = queue
[all...]
/forgerock/openam/openam-core/src/main/java/org/forgerock/openam/cts/worker/process/
H A DCTSWorkerProcessGuiceModule.java29 import org.forgerock.openam.cts.impl.queue.TaskDispatcher;
47 SessionExpiryBatchHandler getMaxSessionExpiryBatchHandler(TaskDispatcher queue, argument
49 return new SessionExpiryBatchHandler(queue, MAX_TIMEOUT, stateChangeResultHandlerFactory);
55 SessionExpiryBatchHandler getIdleTimeoutExpiryBatchHandler(TaskDispatcher queue, argument
57 return new SessionExpiryBatchHandler(queue, IDLE_TIMEOUT, stateChangeResultHandlerFactory);
/forgerock/openam-v13/openam-core/src/main/java/org/forgerock/openam/sm/datalayer/impl/
H A DSeriesTaskExecutorThreadFactory.java44 * @param queue Non null BlockingQueue to assign.
48 public SeriesTaskExecutorThread create(BlockingQueue<Task> queue) { argument
49 Reject.ifNull(queue);
51 processor.setQueue(queue);
H A DSeriesTaskExecutorThread.java34 * makes no assumptions about the nature of the task, or the queue from which
48 private BlockingQueue<Task> queue; field in class:SeriesTaskExecutorThread
67 * @param queue Non null BlockingQueue implementation to use for asynchronous processing.
69 public void setQueue(BlockingQueue<Task> queue) { argument
70 this.queue = queue;
76 * @throws java.lang.IllegalStateException If the queue has not been assigned.
80 if (queue == null) throw new IllegalStateException("Must assign a queue before starting.");
91 Task task = queue
[all...]
/forgerock/openam/openam-core/src/main/java/org/forgerock/openam/sm/datalayer/impl/
H A DSeriesTaskExecutorThreadFactory.java44 * @param queue Non null BlockingQueue to assign.
48 public SeriesTaskExecutorThread create(BlockingQueue<Task> queue) { argument
49 Reject.ifNull(queue);
51 processor.setQueue(queue);
H A DSeriesTaskExecutorThread.java34 * makes no assumptions about the nature of the task, or the queue from which
48 private BlockingQueue<Task> queue; field in class:SeriesTaskExecutorThread
67 * @param queue Non null BlockingQueue implementation to use for asynchronous processing.
69 public void setQueue(BlockingQueue<Task> queue) { argument
70 this.queue = queue;
76 * @throws java.lang.IllegalStateException If the queue has not been assigned.
80 if (queue == null) throw new IllegalStateException("Must assign a queue before starting.");
91 Task task = queue
[all...]
/forgerock/openam/openam-core/src/test/java/org/forgerock/openam/cts/impl/queue/
H A DTaskDispatcherTest.java16 package org.forgerock.openam.cts.impl.queue;
38 private TaskDispatcher queue; field in class:TaskDispatcherTest
55 queue = new TaskDispatcher(
62 queue.startDispatcher();
104 queue.create(token, options, handler);
110 queue.update(token, options, handler);
116 queue.delete(tokenId, handler);
122 queue.read(tokenId, options, handler);
128 queue.query(tokenFilter, handler);
134 queue
[all...]

Completed in 140 milliseconds

12345678