atavism.server.util

Class SquareQueue<K,V>

java.lang.Object

atavism.server.util.SquareQueue<K,V>

public class SquareQueue<K,V>
extends java.lang.Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	SquareQueue.SubQueue

Field Summary

Fields

Modifier and Type	Field and Description
protected java.lang.String	name
protected java.util.concurrent.ConcurrentLinkedQueue<SquareQueue.SubQueue>	queue
protected java.util.concurrent.ConcurrentHashMap<K,SquareQueue.SubQueue>	subQueues

Constructor Summary

Constructors

Constructor and Description
SquareQueue(java.lang.String name)

Method Summary

Modifier and Type	Method and Description
java.lang.String	getName()
protected boolean	getNext(SquareQueue.SubQueue subQueue)
int	getSQSize()
protected int	getSubQueueSize(SquareQueue.SubQueue subQueue)
void	insert(K key, V value)
void	insert(java.util.List<K> keys, V value)
static void	main(java.lang.String[] args)
protected SquareQueue.SubQueue	newSubQueue(K key)
SquareQueue.SubQueue	remove()
void	removeKey(K key)
void	requeue(SquareQueue.SubQueue subQueue)

Methods inherited from class java.lang.Object

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

Field Detail

subQueues

protected java.util.concurrent.ConcurrentHashMap<K,SquareQueue.SubQueue> subQueues

queue

protected java.util.concurrent.ConcurrentLinkedQueue<SquareQueue.SubQueue> queue

name

protected java.lang.String name

Constructor Detail

SquareQueue

public SquareQueue(java.lang.String name)

Method Detail

insert

public void insert(K key,
                   V value)

insert

public void insert(java.util.List<K> keys,
                   V value)

remove

public SquareQueue.SubQueue remove()
                            throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

requeue

public void requeue(SquareQueue.SubQueue subQueue)

removeKey

public void removeKey(K key)

getSQSize

public int getSQSize()

getName

public java.lang.String getName()

getNext

protected boolean getNext(SquareQueue.SubQueue subQueue)

getSubQueueSize

protected int getSubQueueSize(SquareQueue.SubQueue subQueue)

newSubQueue

protected SquareQueue.SubQueue newSubQueue(K key)

main

public static void main(java.lang.String[] args)