oemware.core
Class SynchQueue

java.lang.Object
  oemware.core.SynchQueue

public final class SynchQueue
extends java.lang.Object

The synchronous (blocking) queue.

Constructor Summary

SynchQueue()
Construct a new queue (default not fair).

SynchQueue(boolean pFair)
Construct a new queue.

Method Summary

void	put(java.lang.Object pObj) Add an element.
void	shutdown() Stop the queue.
void	startup()
java.lang.Object	take() Take the object.

Methods inherited from class java.lang.Object

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

Constructor Detail

SynchQueue

public SynchQueue(boolean pFair)

Construct a new queue.

Parameters:

pFair - Set to true fo fair.

SynchQueue

public SynchQueue()

Construct a new queue (default not fair).

Method Detail

take

public final java.lang.Object take()
                            throws java.lang.InterruptedException

Take the object. Blocks if no object.

Returns:

The new object.

Throws:

java.lang.InterruptedException

put

public final void put(java.lang.Object pObj)
               throws java.lang.InterruptedException

Add an element.

Throws:

java.lang.InterruptedException

shutdown

public final void shutdown()

Stop the queue.

startup

public final void startup()