Top Description Fields Constructors Methods

com.ziclix.python.sql.util

public Class Queue

Class Inheritance

extends Object

java.lang.Object
com.ziclix.python.sql.util.Queue

Imports

java.util.LinkedList

This queue blocks until closed or an element is enqueued. If the queue reaches capacity, the dequeue thread gets priority in order to bring the queue size under a certain threshold.

Author: brian zimmer

Field Summary

Modifier and Type	Field and Description
protected int	capacity Field capacity, threshold
protected boolean	closed Field closed
protected LinkedList<Object>	queue Field queue
protected int	threshold Field capacity, threshold

Constructor Summary

Access	Constructor and Description
public	Queue() Instantiate a blocking queue with no bounded capacity.
public	Queue(int capacity) Instantiate a blocking queue with the specified capacity.

Method Summary

Modifier and Type	Method and Description
public synchronized void	close() Close the queue and notify all waiting Threads.
public synchronized Object	dequeue() Blocks until an object is dequeued or the queue is closed.
public synchronized void	enqueue(Object element) Enqueue an object and notify all waiting Threads.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

capacity	back to summary
protected int capacity Field capacity, threshold

closed	back to summary
protected boolean closed Field closed

queue	back to summary
protected LinkedList<Object> queue Field queue

threshold	back to summary
protected int threshold Field capacity, threshold

Constructor Detail

Queue	back to summary
public Queue() Instantiate a blocking queue with no bounded capacity.

Queue	back to summary
public Queue(int capacity) Instantiate a blocking queue with the specified capacity.

Method Detail

close	back to summary
public synchronized void close() Close the queue and notify all waiting Threads.

dequeue	back to summary
public synchronized Object dequeue() throws InterruptedException Blocks until an object is dequeued or the queue is closed.

enqueue	back to summary
public synchronized void enqueue(Object element) throws InterruptedException Enqueue an object and notify all waiting Threads.