org.gudy.azureus2.core3.util
Class ThreadPool
java.lang.Object
org.gudy.azureus2.core3.util.ThreadPool
public class ThreadPool
- extends java.lang.Object
Constructor Summary |
ThreadPool(java.lang.String _name,
int _max_size)
|
ThreadPool(java.lang.String _name,
int _max_size,
boolean _queue_when_full)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
ThreadPool
public ThreadPool(java.lang.String _name,
int _max_size)
ThreadPool
public ThreadPool(java.lang.String _name,
int _max_size,
boolean _queue_when_full)
checkAllTimeouts
protected static void checkAllTimeouts()
setWarnWhenFull
public void setWarnWhenFull()
setLogCPU
public void setLogCPU()
getMaxThreads
public int getMaxThreads()
setThreadPriority
public void setThreadPriority(int _priority)
setExecutionLimit
public void setExecutionLimit(long millis)
run
public org.gudy.azureus2.core3.util.ThreadPool.threadPoolWorker run(AERunnable runnable)
run
public org.gudy.azureus2.core3.util.ThreadPool.threadPoolWorker run(AERunnable runnable,
boolean high_priority,
boolean manualRelease)
- Parameters:
runnable
- high_priority
- inserts at front if tasks queueing
runIt
protected void runIt(AERunnable runnable)
checkWarning
protected void checkWarning()
getQueuedTasks
public AERunnable[] getQueuedTasks()
getQueueSize
public int getQueueSize()
isQueued
public boolean isQueued(AERunnable task)
getRunningTasks
public AERunnable[] getRunningTasks()
getRunningCount
public int getRunningCount()
isFull
public boolean isFull()
setMaxThreads
public void setMaxThreads(int max)
setReservedThreadCount
public void setReservedThreadCount(int res)
checkTimeouts
protected void checkTimeouts()
getName
public java.lang.String getName()
registerThreadAsChild
public void registerThreadAsChild(org.gudy.azureus2.core3.util.ThreadPool.threadPoolWorker parent)
deregisterThreadAsChild
public void deregisterThreadAsChild(org.gudy.azureus2.core3.util.ThreadPool.threadPoolWorker parent)