Package com.sun.corba.ee.impl.transport.concurrent

Class ConcurrentQueueNonBlockingImpl<V>

java.lang.Object

com.sun.corba.ee.impl.transport.concurrent.ConcurrentQueueNonBlockingImpl<V>

All Implemented Interfaces:

ConcurrentQueue<V>

public class ConcurrentQueueNonBlockingImpl<V>
extends Object
implements ConcurrentQueue<V>

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private final class	ConcurrentQueueNonBlockingImpl.Entry<V>
private final class	ConcurrentQueueNonBlockingImpl.HandleImpl<V>

Nested classes/interfaces inherited from interface com.sun.corba.ee.spi.transport.concurrent.ConcurrentQueue

ConcurrentQueue.Handle<V>

Field Summary

Fields

Modifier and Type	Field	Description
(package private) int	count
(package private) final ConcurrentQueueNonBlockingImpl<V>.Entry<V>	head
(package private) final Object	lock
private long	ttl

Constructor Summary

Constructors

Constructor	Description
ConcurrentQueueNonBlockingImpl(long ttl)

Method Summary

Modifier and Type	Method	Description
ConcurrentQueue.Handle<V>	offer(V arg)	Add a new element to the tail of the queue.
ConcurrentQueue.Handle<V>	peek()	Return the handle for the head of the queue.
ConcurrentQueue.Handle<V>	poll()	Return an element from the head of the queue.
int	size()	Return the number of elements in the queue.

Methods inherited from class java.lang.Object

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

Field Details

head

final ConcurrentQueueNonBlockingImpl<V>.Entry<V> head

lock

final Object lock

count

int count

ttl

private long ttl

Constructor Details

ConcurrentQueueNonBlockingImpl

public ConcurrentQueueNonBlockingImpl(long ttl)

Method Details

size

public int size()

Description copied from interface: ConcurrentQueue

Return the number of elements in the queue.

Specified by:

size in interface ConcurrentQueue<V>

Returns:

the number of elements

offer

public ConcurrentQueue.Handle<V> offer(V arg)

Add a new element to the tail of the queue. Returns a handle for the element in the queue.

Specified by:

offer in interface ConcurrentQueue<V>

Parameters:

arg - element to add

Returns:

handle for element

poll

public ConcurrentQueue.Handle<V> poll()

Return an element from the head of the queue. The element is removed from the queue.

Specified by:

poll in interface ConcurrentQueue<V>

Returns:

handle for head of queue

peek

public ConcurrentQueue.Handle<V> peek()

Description copied from interface: ConcurrentQueue

Return the handle for the head of the queue. The element is not removed from the queue.

Specified by:

peek in interface ConcurrentQueue<V>

Returns:

handle for head of queue