com.davidsoergel.conja

Class DepthFirstThreadPoolExecutor

java.lang.Object

com.davidsoergel.conja.DepthFirstThreadPoolExecutor

All Implemented Interfaces:

TreeExecutorService

public class DepthFirstThreadPoolExecutor
extends Object
implements TreeExecutorService

Version:

$Id$

Author:

David Soergel

Constructor Summary

Constructors

Constructor and Description
DepthFirstThreadPoolExecutor()
DepthFirstThreadPoolExecutor(int threads)
DepthFirstThreadPoolExecutor(int threads, int queueSizePerTaskGroup)

Method Summary

Methods

Modifier and Type	Method and Description
static DepthFirstThreadPoolExecutor	getInstance()
int	getPoolSize()
static boolean	hasInstance()
static void	set_instance_cpus(int _instance_cpus)
ThreadPoolPerformanceStats	shutdown()
void	shutdownNow()
void	submitAndWaitForAll(Iterable<Runnable> tasks) Submit a collection of tasks to the thread pool, and block until they complete.
void	submitAndWaitForAll(Iterator<Runnable> tasks) Submit a collection of tasks to the thread pool, and block until they complete.

Methods inherited from class java.lang.Object

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

Constructor Detail

DepthFirstThreadPoolExecutor

public DepthFirstThreadPoolExecutor()

DepthFirstThreadPoolExecutor

public DepthFirstThreadPoolExecutor(int threads)

DepthFirstThreadPoolExecutor

public DepthFirstThreadPoolExecutor(int threads,
                            int queueSizePerTaskGroup)

Method Detail

getInstance

public static DepthFirstThreadPoolExecutor getInstance()

hasInstance

public static boolean hasInstance()

set_instance_cpus

public static void set_instance_cpus(int _instance_cpus)

getPoolSize

public int getPoolSize()

submitAndWaitForAll

public void submitAndWaitForAll(Iterable<Runnable> tasks)

Submit a collection of tasks to the thread pool, and block until they complete. If the caller is running on a worker thread of this very pool, then temporarily increments the maximum number of threads while blocking.

Specified by:

submitAndWaitForAll in interface TreeExecutorService

Parameters:

tasks -

shutdown

public ThreadPoolPerformanceStats shutdown()

Specified by:

shutdown in interface TreeExecutorService

shutdownNow

public void shutdownNow()

submitAndWaitForAll

public void submitAndWaitForAll(Iterator<Runnable> tasks)

Submit a collection of tasks to the thread pool, and block until they complete. If the caller is running on a worker thread of this very pool, then temporarily increments the maximum number of threads while blocking.

Specified by:

submitAndWaitForAll in interface TreeExecutorService

Parameters:

tasks -