Package fr.gouv.vitam.processing.distributor.core

Class WorkerExecutor

java.lang.Object

fr.gouv.vitam.processing.distributor.core.WorkerExecutor

All Implemented Interfaces:

Runnable

public class WorkerExecutor
extends Object
implements Runnable

manage one worker with n thread

Constructor Summary

Constructors

Constructor	Description
WorkerExecutor(PriorityTaskQueue<Runnable> queue, WorkerBean workerBean)

Method Summary

Modifier and Type	Method	Description
WorkerBean	getWorkerBean()
void	run()
void	stop()	send a message to notify all thread that the worker will be stop.

Methods inherited from class java.lang.Object

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

Constructor Details

WorkerExecutor

public WorkerExecutor(PriorityTaskQueue<Runnable> queue,
 WorkerBean workerBean)

Method Details

run

public void run()

Specified by:

run in interface Runnable

stop

public void stop()

send a message to notify all thread that the worker will be stop.

getWorkerBean

public WorkerBean getWorkerBean()