org.ow2.proactive.resourcemanager.nodesource

Class ThreadPoolHolder

java.lang.Object

org.ow2.proactive.resourcemanager.nodesource.ThreadPoolHolder

public class ThreadPoolHolder
extends Object

Class to hold a number of independent thread pools. Provides a synchronous access to pools allowing to submit tasks to them.

Constructor Summary

Constructors

Constructor and Description
ThreadPoolHolder(int[] poolSizes, org.objectweb.proactive.utils.NamedThreadFactory[] threadFactories) Instantiates the thread pools.

Method Summary

Modifier and Type	Method and Description
void	execute(int num, Runnable task) Executes a task in the specified thread pool
void	shutdown(int num, int totalMaxWaitTime)
void	shutdownNow(int num)
<T> Future<T>	submit(int num, Callable<T> task) Submits a task to the specified thread pool

Methods inherited from class java.lang.Object

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

Constructor Detail

ThreadPoolHolder

public ThreadPoolHolder(int[] poolSizes,
                        org.objectweb.proactive.utils.NamedThreadFactory[] threadFactories)

Instantiates the thread pools.

Method Detail

submit

public <T> Future<T> submit(int num,
                            Callable<T> task)

Submits a task to the specified thread pool

Parameters:

num - thread pool index

task - to be submitted

Returns:

the future result of the task

execute

public void execute(int num,
                    Runnable task)

Executes a task in the specified thread pool

Parameters:

num - thread pool index

task - to be executed

shutdown

public void shutdown(int num,
                     int totalMaxWaitTime)

shutdownNow

public void shutdownNow(int num)