com.j_spaces.kernel.threadpool.queue

Class DynamicQueue<E>

java.lang.Object

java.util.AbstractCollection<E>

java.util.AbstractQueue<E>

java.util.concurrent.LinkedBlockingQueue<E>

com.j_spaces.kernel.threadpool.queue.DynamicQueue<E>

All Implemented Interfaces:

Serializable, Iterable<E>, Collection<E>, BlockingQueue<E>, Queue<E>

public class DynamicQueue<E>
extends LinkedBlockingQueue<E>

Much like a SynchronousQueue which acts as a rendezvous channel. It is well suited for handoff designs, in which a tasks is only queued if there is an available thread to pick it up.

This queue is correlated with a thread-pool, and allows insertions to the queue only if there is a free thread that can poll this task. Otherwise, the task is rejected and the decision is left up to one of the RejectedExecutionHandler policies:

1. ForceQueuePolicy - forces the queue to accept the rejected task.
2. TimedBlockingPolicy - waits for a given time for the task to be executed.

Since:

6.5

Author:

moran

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
DynamicQueue() Creates a DynamicQueue with a capacity of Integer.MAX_VALUE.
DynamicQueue(int capacity) Creates a DynamicQueue with the given (fixed) capacity.

Method Summary

Modifier and Type	Method and Description
boolean	offer(E o) Inserts the specified element at the tail of this queue if there is at least one available thread to run the current task.
void	setThreadPoolExecutor(ThreadPoolExecutor executor) Sets the executor this queue belongs to.

Methods inherited from class java.util.concurrent.LinkedBlockingQueue

clear, contains, drainTo, drainTo, iterator, offer, peek, poll, poll, put, remainingCapacity, remove, size, spliterator, take, toArray, toArray, toString

Methods inherited from class java.util.AbstractQueue

add, addAll, element, remove

Methods inherited from class java.util.AbstractCollection

containsAll, isEmpty, removeAll, retainAll

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface java.util.concurrent.BlockingQueue

add

Methods inherited from interface java.util.Queue

element, remove

Methods inherited from interface java.util.Collection

addAll, containsAll, equals, hashCode, isEmpty, parallelStream, removeAll, removeIf, retainAll, stream

Methods inherited from interface java.lang.Iterable

forEach

Constructor Detail

DynamicQueue

public DynamicQueue()

Creates a DynamicQueue with a capacity of Integer.MAX_VALUE.

DynamicQueue

public DynamicQueue(int capacity)

Creates a DynamicQueue with the given (fixed) capacity.

Parameters:

capacity - the capacity of this queue.

Method Detail

setThreadPoolExecutor

public void setThreadPoolExecutor(ThreadPoolExecutor executor)

Sets the executor this queue belongs to.

offer

public boolean offer(E o)

Inserts the specified element at the tail of this queue if there is at least one available thread to run the current task. If all pool threads are actively busy, it rejects the offer.

Specified by:

offer in interface BlockingQueue<E>

Specified by:

offer in interface Queue<E>

Overrides:

offer in class LinkedBlockingQueue<E>

Parameters:

o - the element to add.

Returns:

true if it was possible to add the element to this queue, else false

See Also:

ThreadPoolExecutor.execute(Runnable)