Uses of Interface
org.compass.core.util.backport.java.util.concurrent.BlockingQueue

Packages that use BlockingQueue

org.compass.core.util.backport.java.util.concurrent

Utility classes commonly useful in concurrent programming.

Uses of BlockingQueue in org.compass.core.util.backport.java.util.concurrent

Subinterfaces of BlockingQueue in org.compass.core.util.backport.java.util.concurrent

interface

BlockingDeque A Deque that additionally supports blocking operations that wait for the deque to become non-empty when retrieving an element, and wait for space to become available in the deque when storing an element.

Classes in org.compass.core.util.backport.java.util.concurrent that implement BlockingQueue

class	ArrayBlockingQueue A bounded blocking queue backed by an array.
class	DelayQueue An unbounded blocking queue of Delayed elements, in which an element can only be taken when its delay has expired.
class	LinkedBlockingDeque An optionally-bounded blocking deque based on linked nodes.
class	LinkedBlockingQueue An optionally-bounded blocking queue based on linked nodes.
class	PriorityBlockingQueue An unbounded blocking queue that uses the same ordering rules as class PriorityQueue and supplies blocking retrieval operations.
class	SynchronousQueue A blocking queue in which each insert operation must wait for a corresponding remove operation by another thread, and vice versa.

Methods in org.compass.core.util.backport.java.util.concurrent that return BlockingQueue

BlockingQueue	ThreadPoolExecutor.getQueue() Returns the task queue used by this executor.
BlockingQueue	ScheduledThreadPoolExecutor.getQueue() Returns the task queue used by this executor.

Constructors in org.compass.core.util.backport.java.util.concurrent with parameters of type BlockingQueue

ExecutorCompletionService(Executor executor, BlockingQueue completionQueue)
Creates an ExecutorCompletionService using the supplied executor for base task execution and the supplied queue as its completion queue.

ThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue workQueue)
Creates a new ThreadPoolExecutor with the given initial parameters and default thread factory and rejected execution handler.

ThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue workQueue, RejectedExecutionHandler handler)
Creates a new ThreadPoolExecutor with the given initial parameters and default thread factory.

ThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue workQueue, ThreadFactory threadFactory)
Creates a new ThreadPoolExecutor with the given initial parameters and default rejected execution handler.

ThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue workQueue, ThreadFactory threadFactory, RejectedExecutionHandler handler)
Creates a new ThreadPoolExecutor with the given initial parameters.