org.agilewiki.jactor.concurrent

Class JAThreadManager

java.lang.Object

org.agilewiki.jactor.concurrent.JAThreadManager

All Implemented Interfaces:

ThreadManager

public final class JAThreadManager
extends Object
implements ThreadManager

A high performance implementation of ThreadManager.

Constructor Summary

Constructors

Constructor and Description
JAThreadManager()

Method Summary

Methods

Modifier and Type	Method and Description
void	close() The close method is used to stop all the threads as they become idle.
void	logException(boolean fatal, String msg, Exception exception)
static ThreadManager	newThreadManager(int threadCount) Create a JAThreadManager
static ThreadManager	newThreadManager(int threadCount, ThreadFactory threadFactory) Create a JAThreadManager
void	process(Runnable task) Begin running a task.
void	start(int threadCount, ThreadFactory threadFactory) Create and start the concurrent.

Methods inherited from class java.lang.Object

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

Constructor Detail

JAThreadManager

public JAThreadManager()

Method Detail

newThreadManager

public static ThreadManager newThreadManager(int threadCount)

Create a JAThreadManager

Parameters:

threadCount - The number of concurrent to be used.

Returns:

A new JAThreadManager.

newThreadManager

public static ThreadManager newThreadManager(int threadCount,
                             ThreadFactory threadFactory)

Create a JAThreadManager

Parameters:

threadCount - The number of concurrent to be used.

threadFactory - Used to create the concurrent.

Returns:

A new JAThreadManager.

start

public final void start(int threadCount,
         ThreadFactory threadFactory)

Create and start the concurrent.

Specified by:

start in interface ThreadManager

Parameters:

threadCount - The number of concurrent to be used.

threadFactory - Used to create the concurrent.

process

public final void process(Runnable task)

Begin running a task.

Specified by:

process in interface ThreadManager

Parameters:

task - A task to be processed on another thread.

close

public final void close()

The close method is used to stop all the threads as they become idle. This method sets a flag to indicate that the concurrent should stop and then wakes up all the concurrent. This method only returns after all the threads have died.

Specified by:

close in interface ThreadManager

logException

public void logException(boolean fatal,
                String msg,
                Exception exception)

Specified by:

logException in interface ThreadManager