xyz.cofe.ipc.process

Class TaskManager

java.lang.Object

xyz.cofe.ipc.process.TaskManager

public class TaskManager
extends Object

Менеджер задач. Содержит в своем составе пул потоков и очередь заданий

Author:

gocha

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	TaskManager.Adapter Адаптер подписчика на сообщения
static class	TaskManager.Event Событие менеджера задач.
static class	TaskManager.JobCancelQueueEvent Событие очереди
static class	TaskManager.JobExecuteEvent Событие выполнения задания
static class	TaskManager.JobQueueEvent Событие очереди
static interface	TaskManager.Listener Подписчик на события менеджера задач
static class	TaskManager.QueueAction Действие очереди
static class	TaskManager.ThreadAction Действие потока
static class	TaskManager.ThreadEvet События происходящие в потоке
static class	TaskManager.ThreadPoolAction
static class	TaskManager.ThreadPoolEvent

Constructor Summary

Constructors

Constructor and Description
TaskManager()

Method Summary

Modifier and Type	Method and Description
void	addListener(TaskManager.Listener l) Добавляет подписчика
void	addThreads(int count) Добавляет указанное кол-во потоков в пул
protected Thread	createThread() Создание класса потока
protected void	fireEvent(TaskManager.Event e) Сообщает о наступлении события подписчикам
long	getDestroyThreadTimeout() Указывает время уничтожения потока в милисикундах (по умолч. 15 секунд)
Collection<TaskManager.Listener>	getListeners() Возвращает набор подписчиков на события
int	getLiveThreadsCount() Возвращает кол-во живых потоков
Queue<Runnable>	getQueue() Возвращает очередь с заданиями
int	getThreadPoolSize() Указывает кол-во потоков
long	getThreadSleepTimeout()
boolean	isRunning() Возвращает флаг активности
boolean	isThreadDeamon() Указывает использовать daemon режим
void	removeListener(TaskManager.Listener l) Удаляет подписчика
int	removeThreads(int count) Удаляет указанное кол-во потоков из пула
void	setDestroyThreadTimeout(long destroyThreadTimeout) Указывает время уничтожения потока в милисикундах (по умолч. 15 секунд)
void	setThreadDeamon(boolean threadDeamon)
void	setThreadPoolSize(int threadPoolSize) Указывает кол-во потоков
void	setThreadSleepTimeout(long threadSleepTimeout)
void	start() Инициализация пула потоков
void	stop() Уничтожение пула потоков

Methods inherited from class java.lang.Object

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

Constructor Detail

TaskManager

public TaskManager()

Method Detail

getThreadPoolSize

public int getThreadPoolSize()

Указывает кол-во потоков

Returns:

Кол-во потоков

setThreadPoolSize

public void setThreadPoolSize(int threadPoolSize)

Указывает кол-во потоков

Parameters:

threadPoolSize - Кол-во потоков

getDestroyThreadTimeout

public long getDestroyThreadTimeout()

Указывает время уничтожения потока в милисикундах (по умолч. 15 секунд)

Returns:

время уничтожения потока в милисик.

setDestroyThreadTimeout

public void setDestroyThreadTimeout(long destroyThreadTimeout)

Указывает время уничтожения потока в милисикундах (по умолч. 15 секунд)

Parameters:

destroyThreadTimeout - время уничтожения потока в милисик.

isThreadDeamon

public boolean isThreadDeamon()

Указывает использовать daemon режим

Returns:

true - daemon режим

setThreadDeamon

public void setThreadDeamon(boolean threadDeamon)

getThreadSleepTimeout

public long getThreadSleepTimeout()

setThreadSleepTimeout

public void setThreadSleepTimeout(long threadSleepTimeout)

getListeners

public Collection<TaskManager.Listener> getListeners()

Возвращает набор подписчиков на события

Returns:

Подписчики

addListener

public void addListener(TaskManager.Listener l)

Добавляет подписчика

Parameters:

l - Подписчик

removeListener

public void removeListener(TaskManager.Listener l)

Удаляет подписчика

Parameters:

l - Подписчик

fireEvent

protected void fireEvent(TaskManager.Event e)

Сообщает о наступлении события подписчикам

Parameters:

e - Событие

getQueue

public final Queue<Runnable> getQueue()

Возвращает очередь с заданиями

Returns:

Очередь

createThread

protected Thread createThread()

Создание класса потока

Returns:

Поток

start

public void start()

Инициализация пула потоков

stop

public void stop()

Уничтожение пула потоков

isRunning

public boolean isRunning()

Возвращает флаг активности

Returns:

true - Активен;

getLiveThreadsCount

public int getLiveThreadsCount()

Возвращает кол-во живых потоков

Returns:

кол-во живых потоков

addThreads

public void addThreads(int count)

Добавляет указанное кол-во потоков в пул

Parameters:

count - Кол-во потоков

removeThreads

public int removeThreads(int count)

Удаляет указанное кол-во потоков из пула

Parameters:

count - Кол-во потоков

Returns:

Кол-во удаленных потоков