Package com.luna.common.worker

Class SyncTaskWorker<T>

java.lang.Object

com.luna.common.worker.SyncTaskWorker<T>

All Implemented Interfaces:

Runnable

public abstract class SyncTaskWorker<T>
extends Object
implements Runnable

任务worker

Version:

1.0

Field Summary

Fields

Modifier and Type	Field	Description
final LinkedBlockingQueue<T>	taskQueue	任务队列
final ExecutorService	threadPool	任务线程

Constructor Summary

Constructors

Constructor	Description
SyncTaskWorker(ExecutorService threadPool)
SyncTaskWorker(LinkedBlockingQueue<T> taskQueue, ExecutorService threadPool, com.google.common.util.concurrent.RateLimiter rateLimiter)

Method Summary

Modifier and Type	Method	Description
void	getTask()
abstract List<T>	getTaskList()
abstract void	handleTask(T task)
abstract void	init()	initialize the task queue size
void	run()

Methods inherited from class java.lang.Object

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

Field Details

taskQueue

public final LinkedBlockingQueue<T> taskQueue

任务队列

threadPool

public final ExecutorService threadPool

任务线程

Constructor Details

SyncTaskWorker

public SyncTaskWorker(LinkedBlockingQueue<T> taskQueue,
 ExecutorService threadPool,
 com.google.common.util.concurrent.RateLimiter rateLimiter)

SyncTaskWorker

public SyncTaskWorker(ExecutorService threadPool)

Method Details

init

public abstract void init()

initialize the task queue size

getTaskList

public abstract List<T> getTaskList()

handleTask

public abstract void handleTask(T task)

run

public void run()

Specified by:

run in interface Runnable

getTask

public void getTask()