atavism.server.util

Class SQThreadPool<K,V>

java.lang.Object

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

All Implemented Interfaces:

java.lang.Runnable

public class SQThreadPool<K,V>
extends java.lang.Object
implements java.lang.Runnable

Field Summary

Fields

Modifier and Type	Field and Description
protected SQCallback<K,V>	callback
protected SquareQueue<K,V>	sq
protected java.util.concurrent.atomic.AtomicInteger	threadId

Constructor Summary

Constructors

Constructor and Description
SQThreadPool(SquareQueue<K,V> sq, SQCallback<K,V> callback)
SQThreadPool(SquareQueue<K,V> sq, SQCallback<K,V> callback, int threads)

Method Summary

Modifier and Type	Method and Description
static void	main(java.lang.String[] args)
void	run()

Methods inherited from class java.lang.Object

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

Field Detail

sq

protected SquareQueue<K,V> sq

callback

protected SQCallback<K,V> callback

threadId

protected java.util.concurrent.atomic.AtomicInteger threadId

Constructor Detail

SQThreadPool

public SQThreadPool(SquareQueue<K,V> sq,
                    SQCallback<K,V> callback)

SQThreadPool

public SQThreadPool(SquareQueue<K,V> sq,
                    SQCallback<K,V> callback,
                    int threads)

Method Detail

run

public void run()

Specified by:

run in interface java.lang.Runnable

main

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