fr.gouv.vitam.processing.distributor.v2

Class WorkerExecutor

java.lang.Object

fr.gouv.vitam.processing.distributor.v2.WorkerExecutor

All Implemented Interfaces:

Runnable

public class WorkerExecutor
extends Object
implements Runnable

manage one worker with n thread

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and 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 Detail

WorkerExecutor

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

Method Detail

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()