public class SQThreadPool
extends java.lang.Object
implements java.lang.Runnable
| Modifier and Type | Field and Description |
|---|---|
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 and Description |
|---|
SQThreadPool(SquareQueue sq,
SQCallback callback) |
| Modifier and Type | Method and Description |
|---|---|
void |
doneBlocking() |
static SQThreadPool |
getRunningPool() |
SquareQueue |
getSquareQueue() |
static void |
main(java.lang.String[] args) |
void |
run() |
void |
runningThreadWillBlock() |
protected static java.lang.ThreadLocal<SQThreadPool> selfPool
protected static java.lang.ThreadLocal<atavism.server.util.SQThreadPool.ThreadStatus> threadStatus
protected SquareQueue sq
protected SQCallback callback
protected int total
protected int running
protected int blocking
protected int threadId
public SQThreadPool(SquareQueue sq, SQCallback callback)
public static SQThreadPool getRunningPool()
public void runningThreadWillBlock()
public void doneBlocking()
public void run()
run in interface java.lang.Runnablepublic SquareQueue getSquareQueue()
public static void main(java.lang.String[] args)