ds.funnel.node.task

Class TaskThreads

java.lang.Object

ds.funnel.node.compnt.NodeComponentImpl

ds.funnel.node.task.TaskThreads

All Implemented Interfaces:

NodeComponent

public class TaskThreads
extends NodeComponentImpl

Constructor Summary

Constructors

Constructor and Description
TaskThreads(int size)

Method Summary

Modifier and Type	Method and Description
void	destroyGroup(java.lang.ThreadGroup inThreadGroup)
int	getNumTasks()
int	getNumThreads()
java.util.List<SuperThreadPool.SubmittedRunnable>	getTasks()
void	joinPool() Wait for the thread pool to shutdown
void	joinPool(int inWaitSeconds) Wait for the thread pool to shutdown
void	setNumThreads(int inNum)
void	submitToPool(ScheduledTask<?> inTask) Use this method when a task must run in a certain thread group.

Methods inherited from class ds.funnel.node.compnt.NodeComponentImpl

getComponentKey, getComponentLink, hashCode, setComponentKey, startComponent, stopComponent

Methods inherited from class java.lang.Object

equals, getClass, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TaskThreads

public TaskThreads(int size)

Method Detail

getNumThreads

public int getNumThreads()

setNumThreads

public void setNumThreads(int inNum)

getNumTasks

public int getNumTasks()

Returns:

The number of pending tasks.

getTasks

public java.util.List<SuperThreadPool.SubmittedRunnable> getTasks()

submitToPool

public void submitToPool(ScheduledTask<?> inTask)
                  throws java.util.concurrent.RejectedExecutionException

Use this method when a task must run in a certain thread group. Using the ScheduledTask.startTaskAsync method is preferred.

Parameters:

inTask -

Throws:

java.util.concurrent.RejectedExecutionException

joinPool

public void joinPool()
              throws java.lang.InterruptedException

Wait for the thread pool to shutdown

Throws:

java.lang.InterruptedException

joinPool

public void joinPool(int inWaitSeconds)
              throws java.lang.InterruptedException

Wait for the thread pool to shutdown

Throws:

java.lang.InterruptedException

destroyGroup

public void destroyGroup(java.lang.ThreadGroup inThreadGroup)