Package it.unimi.di.law.bubing.util

Class LockFreeQueue<T>

java.lang.Object

it.unimi.di.law.bubing.util.LockFreeQueue<T>

public class LockFreeQueue<T>
extends java.lang.Object

A thin layer around a ConcurrentLinkedQueue that exhibits a subset of the available methods, and keeps track in an AtomicLong of the size of the queue, so that size() can return in constant time.

Author:

Sebastiano Vigna

Constructor Summary

Constructors

Constructor	Description
LockFreeQueue()

Method Summary

Modifier and Type	Method	Description
boolean	add(T e)
boolean	equals(java.lang.Object o)
int	hashCode()
T	poll()
long	size()	Returns the (approximate) size of this queue.

Methods inherited from class java.lang.Object

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

Constructor Detail

LockFreeQueue

public LockFreeQueue()

Method Detail

add

public boolean add(T e)

See Also:

Queue.add(Object)

poll

public T poll()

See Also:

Queue.poll()

size

public long size()

Returns the (approximate) size of this queue.

This methods returns in constant time (it is just an AtomicLong.get()). Due to concurrent modifications, the returned value might not reflect the actual number of elements in the queue.

Returns:

the (approximate) size of this queue.

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object

equals

public boolean equals(java.lang.Object o)

Overrides:

equals in class java.lang.Object