wt.util
Class Consumer.SynchronizedQueue

java.lang.Object
  wt.util.Consumer.SynchronizedQueue

All Implemented Interfaces:

Consumer.Queue

Direct Known Subclasses:

FileConsumer.FileConsumerQueue

Enclosing class:

Consumer

protected static class Consumer.SynchronizedQueue

extends Object

implements Consumer.Queue

Provides basic synchronization for a multi-threaded producer/consumer situation.

Field Summary

private LinkedList	buffer
private boolean	closed
private boolean	finalized
private int	maxQueueSize

Constructor Summary

Consumer.SynchronizedQueue(int max_queue_size)

Method Summary

void	close()
Object	dequeue()
void	enqueue(Object next)
void	finalize()
boolean	hasNext()
boolean	isClosed()
boolean	isFinalized()
int	size()

Methods inherited from class java.lang.Object

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

Field Detail

maxQueueSize

private final int maxQueueSize

buffer

private final LinkedList buffer

finalized

private boolean finalized

closed

private boolean closed

Constructor Detail

Consumer.SynchronizedQueue

public Consumer.SynchronizedQueue(int max_queue_size)

Method Detail

enqueue

public void enqueue(Object next)

Specified by:

enqueue in interface Consumer.Queue

hasNext

public boolean hasNext()

Specified by:

hasNext in interface Consumer.Queue

dequeue

public Object dequeue()

Specified by:

dequeue in interface Consumer.Queue

close

public void close()

Specified by:

close in interface Consumer.Queue

isClosed

public boolean isClosed()

Specified by:

isClosed in interface Consumer.Queue

finalize

public void finalize()

Specified by:

finalize in interface Consumer.Queue

isFinalized

public boolean isFinalized()

Specified by:

isFinalized in interface Consumer.Queue

size

public int size()

Specified by:

size in interface Consumer.Queue