xyz.cofe.ipc.process

Class TaskManager.Adapter

java.lang.Object

xyz.cofe.ipc.process.TaskManager.Adapter

All Implemented Interfaces:

TaskManager.Listener

Enclosing class:

TaskManager

public static class TaskManager.Adapter
extends Object
implements TaskManager.Listener

Адаптер подписчика на сообщения

Constructor Summary

Constructors

Constructor and Description
Adapter()

Method Summary

Modifier and Type	Method and Description
protected void	jobExecuteEvent(TaskManager.JobExecuteEvent e) Обрабатывает событие потока, распределяя его по onJobAdd, onJobRemove
protected void	jobQueueEvent(TaskManager.JobQueueEvent e) Обрабатывает событие очереди, распределяя его по onJobAdd, onJobRemove
protected void	onJobAdd(TaskManager src, Runnable job, TaskManager.JobCancelQueueEvent e) Работа добавляется в очередь
protected void	onJobFinished(TaskManager src, Thread thread, Runnable job, Throwable ex)
protected void	onJobRemove(TaskManager src, Runnable job)
protected void	onJobStarted(TaskManager src, Thread thread, Runnable job)
protected void	onThreadPoolStarted(TaskManager src, int liveThreadsCount)
protected void	onThreadPoolStopped(TaskManager src, int liveThreadsCount)
protected void	onThreadStarted(TaskManager src, Thread thread)
protected void	onThreadStopped(TaskManager src, Thread thread)
void	taskManagerEvent(TaskManager.Event e) Обрабатывает событие распределяя его по функциям
protected void	threadEvent(TaskManager.ThreadEvet e) Обрабатывает событие потока, распределяя его по onThreadStarted, onThreadStopped, jobExecuteEvent
protected void	threadPoolEvent(TaskManager.ThreadPoolEvent e) Обрабатывает событие пула, распределяя его по onThreadPoolStarted, onThreadPoolStopped

Methods inherited from class java.lang.Object

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

Constructor Detail

Adapter

public Adapter()

Method Detail

taskManagerEvent

public void taskManagerEvent(TaskManager.Event e)

Обрабатывает событие распределяя его по функциям

Specified by:

taskManagerEvent in interface TaskManager.Listener

Parameters:

e - Событие

See Also:

threadPoolEvent(xyz.cofe.ipc.process.TaskManager.ThreadPoolEvent), threadEvent(xyz.cofe.ipc.process.TaskManager.ThreadEvet), jobQueueEvent(xyz.cofe.ipc.process.TaskManager.JobQueueEvent)

threadPoolEvent

protected void threadPoolEvent(TaskManager.ThreadPoolEvent e)

Обрабатывает событие пула, распределяя его по onThreadPoolStarted, onThreadPoolStopped

Parameters:

e - Событие

See Also:

onThreadStarted(xyz.cofe.ipc.process.TaskManager, java.lang.Thread), onThreadStopped(xyz.cofe.ipc.process.TaskManager, java.lang.Thread)

threadEvent

protected void threadEvent(TaskManager.ThreadEvet e)

Обрабатывает событие потока, распределяя его по onThreadStarted, onThreadStopped, jobExecuteEvent

Parameters:

e - Событие

See Also:

TaskManager.JobExecuteEvent, onThreadStarted(xyz.cofe.ipc.process.TaskManager, java.lang.Thread), onThreadStopped(xyz.cofe.ipc.process.TaskManager, java.lang.Thread)

jobQueueEvent

protected void jobQueueEvent(TaskManager.JobQueueEvent e)

Обрабатывает событие очереди, распределяя его по onJobAdd, onJobRemove

Parameters:

e - Событие

See Also:

onJobAdd(xyz.cofe.ipc.process.TaskManager, java.lang.Runnable, xyz.cofe.ipc.process.TaskManager.JobCancelQueueEvent), onJobRemove(xyz.cofe.ipc.process.TaskManager, java.lang.Runnable)

jobExecuteEvent

protected void jobExecuteEvent(TaskManager.JobExecuteEvent e)

Обрабатывает событие потока, распределяя его по onJobAdd, onJobRemove

Parameters:

e - Событие

See Also:

onJobAdd(xyz.cofe.ipc.process.TaskManager, java.lang.Runnable, xyz.cofe.ipc.process.TaskManager.JobCancelQueueEvent), onJobRemove(xyz.cofe.ipc.process.TaskManager, java.lang.Runnable)

onJobAdd

protected void onJobAdd(TaskManager src,
                        Runnable job,
                        TaskManager.JobCancelQueueEvent e)

Работа добавляется в очередь

Parameters:

src - Источник сообщения

job - Задание

e - Сообщение, с возможностью отмены действия

onJobRemove

protected void onJobRemove(TaskManager src,
                           Runnable job)

onThreadPoolStarted

protected void onThreadPoolStarted(TaskManager src,
                                   int liveThreadsCount)

onThreadPoolStopped

protected void onThreadPoolStopped(TaskManager src,
                                   int liveThreadsCount)

onThreadStarted

protected void onThreadStarted(TaskManager src,
                               Thread thread)

onThreadStopped

protected void onThreadStopped(TaskManager src,
                               Thread thread)

onJobStarted

protected void onJobStarted(TaskManager src,
                            Thread thread,
                            Runnable job)

onJobFinished

protected void onJobFinished(TaskManager src,
                             Thread thread,
                             Runnable job,
                             Throwable ex)