org.apache.river.thread

Class TaskManager

java.lang.Object

org.apache.river.thread.TaskManager

Deprecated.

will be removed from a future release soon.

@Deprecated
public class TaskManager
extends Object

A task manager manages a single queue of tasks, and some number of worker threads. New tasks are added to the tail of the queue. Each thread loops, taking a task from the queue and running it. Each thread looks for a task by starting at the head of the queue and taking the first task (that is not already being worked on) that is not required to run after any of the tasks that precede it in the queue (including tasks that are currently being worked on).

This class uses the Logger named org.apache.river.thread.TaskManager to log information at the following logging levels:

org.apache.river.thread.TaskManager

Level	Description
SEVERE	failure to create a worker thread when no other worker threads exist
WARNING	exceptions thrown by TaskManager.Task methods, and failure to create a worker thread when other worker threads exist

Author:

Sun Microsystems, Inc.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	TaskManager.Task Deprecated. The interface that tasks must implement

Field Summary

Fields

Modifier and Type	Field and Description
protected int	firstPending Deprecated. Index of the first pending task; all earlier tasks are active
protected float	loadFactor Deprecated. Threshold for creating new threads
protected static Logger	logger Deprecated. Logger
protected int	maxThreads Deprecated. Maximum number of threads allowed
protected List	roTasks Deprecated. Read-only view of tasks
protected ArrayList<Runnable>	tasks Deprecated. Active and pending tasks
protected boolean	terminated Deprecated. True if manager has been terminated
protected List	threads Deprecated. Active threads
protected long	timeout Deprecated. Idle time before a thread should exit

Constructor Summary

Constructors

Constructor and Description
TaskManager() Deprecated. Create a task manager with maxThreads = 10, timeout = 15 seconds, and loadFactor = 3.0.
TaskManager(int maxThreads, long timeout, float loadFactor) Deprecated. Create a task manager.

Method Summary

Modifier and Type	Method and Description
void	add(Runnable t) Deprecated. Add a new task.
void	addAll(Collection c) Deprecated. Add all tasks in a collection, in iterator order.
void	addIfNew(TaskManager.Task t) Deprecated. Add a new task if it is not equal to (using the equals method) to any existing active or pending task.
int	getMaxThreads() Deprecated. Return the maximum number of threads to use on tasks.
ArrayList	getPending() Deprecated. Return all pending tasks.
protected boolean	needThread() Deprecated. Return true if a new thread should be created (ignoring maxThreads).
boolean	remove(Runnable t) Deprecated.
boolean	removeIfPending(Runnable t) Deprecated. Remove a task if it is pending (not active).
void	terminate() Deprecated. Interrupt all threads, and stop processing tasks.

Methods inherited from class java.lang.Object

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

Field Detail

logger

protected static final Logger logger

Deprecated.

Logger

tasks

protected final ArrayList<Runnable> tasks

Deprecated.

Active and pending tasks

firstPending

protected int firstPending

Deprecated.

Index of the first pending task; all earlier tasks are active

roTasks

protected final List roTasks

Deprecated.

Read-only view of tasks

threads

protected final List threads

Deprecated.

Active threads

maxThreads

protected final int maxThreads

Deprecated.

Maximum number of threads allowed

timeout

protected final long timeout

Deprecated.

Idle time before a thread should exit

loadFactor

protected final float loadFactor

Deprecated.

Threshold for creating new threads

terminated

protected boolean terminated

Deprecated.

True if manager has been terminated

Constructor Detail

TaskManager

public TaskManager()

Deprecated.

Create a task manager with maxThreads = 10, timeout = 15 seconds, and loadFactor = 3.0.

TaskManager

public TaskManager(int maxThreads,
                   long timeout,
                   float loadFactor)

Deprecated.

Create a task manager.

Parameters:

maxThreads - maximum number of threads to use on tasks

timeout - idle time before a thread exits

loadFactor - threshold for creating new threads. A new thread is created if the total number of runnable tasks (both active and pending) exceeds the number of threads times the loadFactor, and the maximum number of threads has not been reached.

Method Detail

addIfNew

public void addIfNew(TaskManager.Task t)

Deprecated.

Add a new task if it is not equal to (using the equals method) to any existing active or pending task.

add

public void add(Runnable t)

Deprecated.

Add a new task.

addAll

public void addAll(Collection c)

Deprecated.

Add all tasks in a collection, in iterator order.

needThread

protected boolean needThread()

Deprecated.

Return true if a new thread should be created (ignoring maxThreads).

removeIfPending

public boolean removeIfPending(Runnable t)

Deprecated.

Remove a task if it is pending (not active). Object identity (==) is used, not the equals method. Returns true if the task was removed.

remove

public boolean remove(Runnable t)

Deprecated.

terminate

public void terminate()

Deprecated.

Interrupt all threads, and stop processing tasks. Only getPending should be used afterwards.

getPending

public ArrayList getPending()

Deprecated.

Return all pending tasks. A new list is returned each time.

getMaxThreads

public int getMaxThreads()

Deprecated.

Return the maximum number of threads to use on tasks.