org.tinygroup.tinypc.impl

Class AbstractJobCenter

java.lang.Object

org.tinygroup.tinypc.impl.AbstractJobCenter

All Implemented Interfaces:

JobCenter

Direct Known Subclasses:

JobCenterLocal, JobCenterRemote

public class AbstractJobCenter
extends Object
implements JobCenter

Created by luoguo on 14-1-8.

Field Summary

Fields inherited from interface org.tinygroup.tinypc.JobCenter

DEFAULT_PORT

Constructor Summary

Constructors

Constructor and Description
AbstractJobCenter()

Method Summary

Modifier and Type	Method and Description
void	autoMatch() 自动进行匹配，如果有匹配成功的，则予以触发执行
Warehouse	doWork(Work work) 执行一项工作，期望同步得到结果或异常 如果没有合适的工人或包工头进行处理，马上会抛出异常
List<Foreman>	getForeman(String type) 返回组织某种工作的的空闲工头列表
RmiServer	getRmiServer()
List<Worker>	getWorkerList(Work work) 返回具有某种类型的空闲且愿意接受工作的工人列表
List<Work>	getWorkList() 返回所有的工作列表
List<Work>	getWorkList(String type, WorkStatus workStatus) 返回某种类型的某种状态的工作列表
WorkQueue	getWorkQueue() 返回工作队列对象
WorkStatus	getWorkStatus(Work work) 返回指定工作的工作状态
void	registerForeman(Foreman foreman) 注册包工头
void	registerWork(Work work) 注册一份工作，工作情况不需要马上关注。因此也就不用等待，马上返回可以进行其它处理 如果有返回结果，可以通过异步方式，，异步方式可以用后续工作的方式来指定
void	registerWorker(Worker worker) 注册工人
void	replaceWork(Work oldWork, Work newWork)
void	setRmiServer(RmiServer rmiServer)
void	setWorkQueue(WorkQueue workQueue)
void	stop() 职业介绍所关门
void	unregisterForeMan(Foreman foreman) 注销包工头
void	unregisterWork(Work work) 取消工作，在工作没有分配出去之前，可以从职介所注消工作，如果工作已经分配出去，则无法注消
void	unregisterWorker(Worker worker) 注消工人

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractJobCenter

public AbstractJobCenter()

Method Detail

getWorkQueue

public WorkQueue getWorkQueue()

Description copied from interface: JobCenter

返回工作队列对象

Specified by:

getWorkQueue in interface JobCenter

Returns:

setWorkQueue

public void setWorkQueue(WorkQueue workQueue)

getRmiServer

public RmiServer getRmiServer()

Specified by:

getRmiServer in interface JobCenter

setRmiServer

public void setRmiServer(RmiServer rmiServer)
                  throws RemoteException

Specified by:

setRmiServer in interface JobCenter

Throws:

RemoteException

registerWorker

public void registerWorker(Worker worker)
                    throws RemoteException

Description copied from interface: JobCenter

注册工人

Specified by:

registerWorker in interface JobCenter

Throws:

RemoteException

unregisterWorker

public void unregisterWorker(Worker worker)
                      throws RemoteException

Description copied from interface: JobCenter

注消工人

Specified by:

unregisterWorker in interface JobCenter

Throws:

RemoteException

registerWork

public void registerWork(Work work)
                  throws IOException

Description copied from interface: JobCenter

注册一份工作，工作情况不需要马上关注。因此也就不用等待，马上返回可以进行其它处理 如果有返回结果，可以通过异步方式，，异步方式可以用后续工作的方式来指定

Specified by:

registerWork in interface JobCenter

Throws:

IOException

replaceWork

public void replaceWork(Work oldWork,
                        Work newWork)
                 throws RemoteException

Throws:

RemoteException

unregisterWork

public void unregisterWork(Work work)
                    throws RemoteException

Description copied from interface: JobCenter

取消工作，在工作没有分配出去之前，可以从职介所注消工作，如果工作已经分配出去，则无法注消

Specified by:

unregisterWork in interface JobCenter

Throws:

RemoteException

getWorkStatus

public WorkStatus getWorkStatus(Work work)
                         throws RemoteException

Description copied from interface: JobCenter

返回指定工作的工作状态

Specified by:

getWorkStatus in interface JobCenter

Returns:

Throws:

RemoteException

registerForeman

public void registerForeman(Foreman foreman)
                     throws RemoteException

Description copied from interface: JobCenter

注册包工头

Specified by:

registerForeman in interface JobCenter

Throws:

RemoteException

unregisterForeMan

public void unregisterForeMan(Foreman foreman)
                       throws RemoteException

Description copied from interface: JobCenter

注销包工头

Specified by:

unregisterForeMan in interface JobCenter

Throws:

RemoteException

getWorkerList

public List<Worker> getWorkerList(Work work)
                           throws RemoteException

Description copied from interface: JobCenter

返回具有某种类型的空闲且愿意接受工作的工人列表

Specified by:

getWorkerList in interface JobCenter

Returns:

Throws:

RemoteException

getWorkList

public List<Work> getWorkList()
                       throws RemoteException

Description copied from interface: JobCenter

返回所有的工作列表

Specified by:

getWorkList in interface JobCenter

Returns:

Throws:

RemoteException

getWorkList

public List<Work> getWorkList(String type,
                              WorkStatus workStatus)
                       throws RemoteException

Description copied from interface: JobCenter

返回某种类型的某种状态的工作列表

Specified by:

getWorkList in interface JobCenter

Returns:

Throws:

RemoteException

getForeman

public List<Foreman> getForeman(String type)
                         throws RemoteException

Description copied from interface: JobCenter

返回组织某种工作的的空闲工头列表

Specified by:

getForeman in interface JobCenter

Returns:

Throws:

RemoteException

doWork

public Warehouse doWork(Work work)
                 throws IOException

Description copied from interface: JobCenter

执行一项工作，期望同步得到结果或异常 如果没有合适的工人或包工头进行处理，马上会抛出异常

Specified by:

doWork in interface JobCenter

Throws:

IOException

autoMatch

public void autoMatch()
               throws IOException

Description copied from interface: JobCenter

自动进行匹配，如果有匹配成功的，则予以触发执行

Specified by:

autoMatch in interface JobCenter

Throws:

IOException

stop

public void stop()
          throws RemoteException

Description copied from interface: JobCenter

职业介绍所关门

Specified by:

stop in interface JobCenter

Throws:

RemoteException