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

class

SquareQueue.SubQueue

Field Summary

protected java.lang.String	name
protected java.util.LinkedList<SquareQueue.SubQueue>	queue
protected java.util.HashMap<K,SquareQueue.SubQueue>	subQueues

Constructor Summary

SquareQueue(java.lang.String name)

Method Summary

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.HashMap<K,SquareQueue.SubQueue> subQueues

queue

protected java.util.LinkedList<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)