horstmann.ch09_queue2

Class BoundedQueue<E>

java.lang.Object

horstmann.ch09_queue2.BoundedQueue<E>

public class BoundedQueue<E>
extends java.lang.Object

A first-in, first-out bounded collection of objects.

Field Summary

Fields

Modifier and Type	Field and Description
private java.util.ArrayList<E>	elements
private int	head
private java.util.concurrent.locks.Lock	queueLock
private int	size
private java.util.concurrent.locks.Condition	spaceAvailableCondition
private int	tail
private java.util.concurrent.locks.Condition	valueAvailableCondition

Constructor Summary

Constructors

Constructor and Description
BoundedQueue(int capacity) Constructs an empty queue.

Method Summary

Modifier and Type	Method and Description
void	add(E newValue) Appends an object at the tail.
E	remove() Removes the object at the head.

Methods inherited from class java.lang.Object

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

Field Detail

elements

private java.util.ArrayList<E> elements

head

private int head

tail

private int tail

size

private int size

queueLock

private java.util.concurrent.locks.Lock queueLock

spaceAvailableCondition

private java.util.concurrent.locks.Condition spaceAvailableCondition

valueAvailableCondition

private java.util.concurrent.locks.Condition valueAvailableCondition

Constructor Detail

BoundedQueue

public BoundedQueue(int capacity)

Constructs an empty queue.

Parameters:

capacity - the maximum capacity of the queue

Method Detail

remove

public E remove()
         throws java.lang.InterruptedException

Removes the object at the head.

Returns:

the object that has been removed from the queue

Throws:

java.lang.InterruptedException

add

public void add(E newValue)
         throws java.lang.InterruptedException

Appends an object at the tail.

Parameters:

newValue - the object to be appended

Throws:

java.lang.InterruptedException