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

protected int	blocking
protected SQCallback	callback
protected int	running
protected static java.lang.ThreadLocal<SQThreadPool>	selfPool
protected SquareQueue	sq
protected int	threadId
protected static java.lang.ThreadLocal<atavism.server.util.SQThreadPool.ThreadStatus>	threadStatus
protected int	total

Constructor Summary

SQThreadPool(SquareQueue sq, SQCallback callback)

Method Summary

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 int total

running

protected int running

blocking

protected int blocking

threadId

protected int 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)