atavism.server.util

Class SQThreadPool

java.lang.Object

atavism.server.util.SQThreadPool

All Implemented Interfaces:

java.lang.Runnable

public class SQThreadPool
extends java.lang.Object
implements java.lang.Runnable

Field Summary

Fields

Modifier and Type	Field and Description
protected java.util.concurrent.atomic.AtomicInteger	blocking
protected SQCallback	callback
protected java.util.concurrent.atomic.AtomicInteger	running
protected static java.lang.ThreadLocal<SQThreadPool>	selfPool
protected SquareQueue	sq
protected java.util.concurrent.atomic.AtomicInteger	threadId
protected static java.lang.ThreadLocal<atavism.server.util.SQThreadPool.ThreadStatus>	threadStatus
protected java.util.concurrent.atomic.AtomicInteger	total

Constructor Summary

Constructors

Constructor and Description
SQThreadPool(SquareQueue sq, SQCallback callback)

Method Summary

Modifier and Type	Method and Description
void	doneBlocking()
static SQThreadPool	getRunningPool()
SquareQueue	getSquareQueue()
static void	main(java.lang.String[] args)
void	run()
void	runningThreadWillBlock()

Methods inherited from class java.lang.Object

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

Field Detail

selfPool

protected static java.lang.ThreadLocal<SQThreadPool> selfPool

threadStatus

protected static java.lang.ThreadLocal<atavism.server.util.SQThreadPool.ThreadStatus> threadStatus

sq

protected SquareQueue sq

callback

protected SQCallback callback

total

protected java.util.concurrent.atomic.AtomicInteger total

running

protected java.util.concurrent.atomic.AtomicInteger running

blocking

protected java.util.concurrent.atomic.AtomicInteger blocking

threadId

protected java.util.concurrent.atomic.AtomicInteger threadId

Constructor Detail

SQThreadPool

public SQThreadPool(SquareQueue sq,
                    SQCallback callback)

Method Detail

getRunningPool

public static SQThreadPool getRunningPool()

runningThreadWillBlock

public void runningThreadWillBlock()

doneBlocking

public void doneBlocking()

run

public void run()

Specified by:

run in interface java.lang.Runnable

getSquareQueue

public SquareQueue getSquareQueue()

main

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