org.compass.core.util.backport.java.util.concurrent
Class SynchronousQueue.WaitQueue

java.lang.Object
  org.compass.core.util.backport.java.util.concurrent.SynchronousQueue.WaitQueue

All Implemented Interfaces:

Serializable

Direct Known Subclasses:

SynchronousQueue.FifoWaitQueue, SynchronousQueue.LifoWaitQueue

Enclosing class:

SynchronousQueue

abstract static class SynchronousQueue.WaitQueue
extends Object
implements Serializable

Queue to hold waiting puts/takes; specialized to Fifo/Lifo below. These queues have all transient fields, but are serializable in order to recover fairness settings when deserialized.

Constructor Summary

SynchronousQueue.WaitQueue()

Method Summary

(package private) abstract SynchronousQueue.Node	deq() Removes and returns node, or null if empty.
(package private) abstract SynchronousQueue.Node	enq(Object x) Creates, adds, and returns node for x.
(package private) abstract boolean	shouldUnlink(SynchronousQueue.Node node) Returns true if a cancelled node might be on queue.
(package private) abstract void	unlink(SynchronousQueue.Node node) Removes a cancelled node to avoid garbage retention.

Methods inherited from class java.lang.Object

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

Constructor Detail

SynchronousQueue.WaitQueue

SynchronousQueue.WaitQueue()

Method Detail

enq

abstract SynchronousQueue.Node enq(Object x)

Creates, adds, and returns node for x.

deq

abstract SynchronousQueue.Node deq()

Removes and returns node, or null if empty.

unlink

abstract void unlink(SynchronousQueue.Node node)

Removes a cancelled node to avoid garbage retention.

shouldUnlink

abstract boolean shouldUnlink(SynchronousQueue.Node node)

Returns true if a cancelled node might be on queue.