org.tinygroup.tinypc.impl

Class AbstractWorker

java.lang.Object

org.tinygroup.tinypc.impl.AbstractWorker

All Implemented Interfaces:

Serializable, Remote, RemoteObject, ParallelObject, Worker

public abstract class AbstractWorker
extends Object
implements Worker

抽象工人，建议所有的工人都继承自此类 Created by luoguo on 14-1-8.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	cancel

Fields inherited from interface org.tinygroup.tinypc.Worker

WORKER_TYPE

Constructor Summary

Constructors

Constructor and Description
AbstractWorker(String type)

Method Summary

Modifier and Type	Method and Description
boolean	acceptWork(Work work) 默认全部接受
void	cancel()
protected abstract Warehouse	doWork(Work work) 真正的工作处理，在这里，如果提供取消工作需要对isCancel()的值进行判断， 如果是true的时候，表示要停止处理，这个时候要立即返回
String	getId()
String	getType() 返回类型
boolean	isCancel()
void	reset()
Warehouse	work(Work work) 执行工作

Methods inherited from class java.lang.Object

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

Field Detail

cancel

protected volatile boolean cancel

Constructor Detail

AbstractWorker

public AbstractWorker(String type)
               throws RemoteException

Throws:

RemoteException

Method Detail

reset

public void reset()

isCancel

public boolean isCancel()

acceptWork

public boolean acceptWork(Work work)
                   throws RemoteException

默认全部接受

Specified by:

acceptWork in interface Worker

Parameters:

work -

Returns:

Throws:

RemoteException

work

public Warehouse work(Work work)
               throws RemoteException

Description copied from interface: Worker

执行工作

Specified by:

work in interface Worker

Returns:

Throws:

RemoteException

doWork

protected abstract Warehouse doWork(Work work)
                             throws RemoteException

真正的工作处理，在这里，如果提供取消工作需要对isCancel()的值进行判断， 如果是true的时候，表示要停止处理，这个时候要立即返回

Parameters:

work -

Throws:

RemoteException

getType

public String getType()

Description copied from interface: Worker

返回类型

Specified by:

getType in interface ParallelObject

Specified by:

getType in interface Worker

cancel

public void cancel()

getId

public String getId()

Specified by:

getId in interface ParallelObject