EDU.oswego.cs.dl.util.concurrent

Class BoundedBuffer

public class BoundedBuffer extends Object implements BoundedChannel

Efficient array-based bounded buffer class. Adapted from CPJ, chapter 8, which describes design.

[ Introduction to this package. ]

Field Summary
protected Object[]	array_
protected int	emptySlots_
protected Object	putMonitor_ Helper monitor to handle puts.
protected int	putPtr_
protected int	takePtr_
protected int	usedSlots_

Constructor Summary
	BoundedBuffer(int capacity) Create a BoundedBuffer with the given capacity.
	BoundedBuffer() Create a buffer with the current default capacity

Method Summary
int	capacity()
protected Object	extract()
protected void	incEmptySlots()
protected void	incUsedSlots()
protected void	insert(Object x)
boolean	offer(Object x, long msecs)
Object	peek()
Object	poll(long msecs)
void	put(Object x)
int	size() Return the number of elements in the buffer.
Object	take()

Field Detail

array_

protected final Object[] array_

emptySlots_

protected int emptySlots_

putMonitor_

protected final Object putMonitor_

Helper monitor to handle puts.

putPtr_

protected int putPtr_

takePtr_

protected int takePtr_

usedSlots_

protected int usedSlots_

Constructor Detail

BoundedBuffer

public BoundedBuffer(int capacity)

Create a BoundedBuffer with the given capacity.

Throws: IllegalArgumentException if capacity less or equal to zero

BoundedBuffer

public BoundedBuffer()

Create a buffer with the current default capacity

Method Detail

capacity

public int capacity()

extract

protected final Object extract()

incEmptySlots

protected void incEmptySlots()

incUsedSlots

protected void incUsedSlots()

insert

protected final void insert(Object x)

offer

public boolean offer(Object x, long msecs)

peek

public Object peek()

poll

public Object poll(long msecs)

put

public void put(Object x)

size

public int size()

Return the number of elements in the buffer. This is only a snapshot value, that may change immediately after returning.

take

public Object take()