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()
int	getSQSize()
int	getSQUnqueuedSize()
void	insert(K key, V value)
void	insert(java.util.List<K> keys, V value)
static void	main(java.lang.String[] args)
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()

getSQUnqueuedSize

public int getSQUnqueuedSize()

getName

public java.lang.String getName()

main

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