Class ThreadPool<T extends AERunnable>

java.lang.Object

com.biglybt.core.util.ThreadPool<T>

All Implemented Interfaces:

ThreadPoolParent<T>

public class ThreadPool<T extends AERunnable>
extends Object
implements ThreadPoolParent<T>

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) class	ThreadPool.threadPoolWorker

Field Summary

Fields

Modifier and Type	Field	Description
private final List<ThreadPool<T>.threadPoolWorker>	busy
private static boolean	busy_pool_timer_set
private static final List<ThreadPool<?>>	busy_pools
private int	current_permits
private static boolean	debug_thread_pool
private static boolean	debug_thread_pool_log_on
private long	execution_limit
private boolean	is_daemon
private boolean	log_cpu
private static final boolean	LOG_WARNINGS
private final String	name
private static final boolean	NAME_THREADS
private final boolean	queue_when_full
private int	target_permits
private final Average	task_average
private final List<T>	task_queue
private long	task_total
private long	task_total_last
private int	thread_name_index
private int	thread_priority
private final AESemaphore	thread_sem
(package private) static final ThreadLocal<ThreadPoolTask.Worker>	tls
private static final int	WARN_TIME
private boolean	warn_when_full

Constructor Summary

Constructors

Constructor	Description
ThreadPool(String _name, int _max_size)
ThreadPool(String _name, int _max_size, boolean _queue_when_full)

Method Summary

Modifier and Type	Method	Description
protected static void	checkAllTimeouts()
protected void	checkTimeouts()
protected void	checkWarning()
void	deregisterThreadAsChild(ThreadPoolTask.Worker parent)
private void	generateEvidence(IndentWriter writer)
int	getMaxThreads()
String	getName()
AERunnable	getOldestQueuedTask()
AERunnable[]	getQueuedTasks()
int	getQueueSize()
int	getRunningCount()
List<T>	getRunningTasks()
boolean	isFull()
boolean	isQueued(AERunnable task)
void	registerThreadAsChild(ThreadPoolTask.Worker parent)
(package private) void	releaseManual(ThreadPoolTask toRelease)
ThreadPool<T>.threadPoolWorker	run(T runnable)
ThreadPool<T>.threadPoolWorker	run(T runnable, boolean high_priority, boolean manualRelease)
protected void	runIt(AERunnable runnable)
void	runTask(T runnable)
void	runTask(T runnable, boolean high_priority, boolean manualRelease)
void	setDaemon(boolean d)
void	setExecutionLimit(long millis)
void	setLogCPU()
void	setMaxThreads(int max)
void	setThreadPriority(int _priority)
void	setWarnWhenFull()

Methods inherited from class Object

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

Field Details

NAME_THREADS

private static final boolean NAME_THREADS

LOG_WARNINGS

private static final boolean LOG_WARNINGS

See Also:

• Constant Field Values

WARN_TIME

private static final int WARN_TIME

See Also:

• Constant Field Values

busy_pools

private static final List<ThreadPool<?>> busy_pools

busy_pool_timer_set

private static boolean busy_pool_timer_set

debug_thread_pool

private static boolean debug_thread_pool

debug_thread_pool_log_on

private static boolean debug_thread_pool_log_on

tls

static final ThreadLocal<ThreadPoolTask.Worker> tls

name

private final String name

thread_name_index

private int thread_name_index

execution_limit

private long execution_limit

busy

private final List<ThreadPool<T extends AERunnable>.threadPoolWorker> busy

queue_when_full

private final boolean queue_when_full

task_queue

private final List<T extends AERunnable> task_queue

thread_sem

private final AESemaphore thread_sem

target_permits

private int target_permits

current_permits

private int current_permits

thread_priority

private int thread_priority

is_daemon

private boolean is_daemon

warn_when_full

private boolean warn_when_full

task_total

private long task_total

task_total_last

private long task_total_last

task_average

private final Average task_average

log_cpu

private boolean log_cpu

Constructor Details

ThreadPool

public ThreadPool(String _name,
 int _max_size)

ThreadPool

public ThreadPool(String _name,
 int _max_size,
 boolean _queue_when_full)

Method Details

checkAllTimeouts

protected static void checkAllTimeouts()

generateEvidence

private void generateEvidence(IndentWriter writer)

setWarnWhenFull

public void setWarnWhenFull()

Specified by:

setWarnWhenFull in interface ThreadPoolParent<T extends AERunnable>

setLogCPU

public void setLogCPU()

getMaxThreads

public int getMaxThreads()

Specified by:

getMaxThreads in interface ThreadPoolParent<T extends AERunnable>

setThreadPriority

public void setThreadPriority(int _priority)

setDaemon

public void setDaemon(boolean d)

setExecutionLimit

public void setExecutionLimit(long millis)

runTask

public void runTask(T runnable)

Specified by:

runTask in interface ThreadPoolParent<T extends AERunnable>

runTask

public void runTask(T runnable,
 boolean high_priority,
 boolean manualRelease)

Specified by:

runTask in interface ThreadPoolParent<T extends AERunnable>

run

public ThreadPool<T>.threadPoolWorker run(T runnable)

run

public ThreadPool<T>.threadPoolWorker run(T 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()

getOldestQueuedTask

public AERunnable getOldestQueuedTask()

getQueueSize

public int getQueueSize()

isQueued

public boolean isQueued(AERunnable task)

Specified by:

isQueued in interface ThreadPoolParent<T extends AERunnable>

getRunningTasks

public List<T> getRunningTasks()

Specified by:

getRunningTasks in interface ThreadPoolParent<T extends AERunnable>

getRunningCount

public int getRunningCount()

Specified by:

getRunningCount in interface ThreadPoolParent<T extends AERunnable>

isFull

public boolean isFull()

Specified by:

isFull in interface ThreadPoolParent<T extends AERunnable>

setMaxThreads

public void setMaxThreads(int max)

Specified by:

setMaxThreads in interface ThreadPoolParent<T extends AERunnable>

checkTimeouts

protected void checkTimeouts()

getName

public String getName()

Specified by:

getName in interface ThreadPoolParent<T extends AERunnable>

releaseManual

void releaseManual(ThreadPoolTask toRelease)

registerThreadAsChild

public void registerThreadAsChild(ThreadPoolTask.Worker parent)

Specified by:

registerThreadAsChild in interface ThreadPoolParent<T extends AERunnable>

deregisterThreadAsChild

public void deregisterThreadAsChild(ThreadPoolTask.Worker parent)

Specified by:

deregisterThreadAsChild in interface ThreadPoolParent<T extends AERunnable>