org.openecomp.sdc.be.model.cache.workers

Class CacheWorker

java.lang.Object

org.openecomp.sdc.be.model.cache.workers.CacheWorker

All Implemented Interfaces:

Runnable, IWorker

public class CacheWorker
extends Object
implements Runnable, IWorker

Created by mlando on 9/6/2016. the class represents a worker the pull job from a queue and evacuates them.

Constructor Summary

Constructors

Constructor and Description
CacheWorker(String workerName, LinkedBlockingQueue<Job> jobQueue) constructor

Method Summary

Modifier and Type	Method and Description
void	run() the method will try to get a job if one is avilable it will be retrived and handled.
void	shutDown() the method sets the shutdown flag, when set the worker will stop it's execution as soon as possible with out completing its work

Methods inherited from class java.lang.Object

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

Constructor Detail

CacheWorker

public CacheWorker(String workerName,
                   LinkedBlockingQueue<Job> jobQueue)

constructor

Parameters:

workerName - the name of the given worker

jobQueue - the queue the worker will block on.

Method Detail

run

public void run()

the method will try to get a job if one is avilable it will be retrived and handled. if no jobs are available the worker will block for 500 milliseconds and then it wil check if it needs to shutdown. if not it will block again and so on until sutdown or a new job is available

Specified by:

run in interface Runnable

shutDown

public void shutDown()

the method sets the shutdown flag, when set the worker will stop it's execution as soon as possible with out completing its work

Specified by:

shutDown in interface IWorker