org.tinygroup.tinypc

Interface JobCenter

All Known Implementing Classes:

AbstractJobCenter, JobCenterLocal, JobCenterRemote

public interface JobCenter

职介所 职介所是分布式处理的核心场所，所有工作相关的元素都要通过职介所进行关联 Created by luoguo on 14-1-8.

Field Summary

Fields

Modifier and Type	Field and Description
static int	DEFAULT_PORT

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	setRmiServer(RmiServer rmiServer)
void	stop() 职业介绍所关门
void	unregisterForeMan(Foreman foreman) 注销包工头
void	unregisterWork(Work work) 取消工作，在工作没有分配出去之前，可以从职介所注消工作，如果工作已经分配出去，则无法注消
void	unregisterWorker(Worker worker) 注消工人

Field Detail

DEFAULT_PORT

static final int DEFAULT_PORT

See Also:

Constant Field Values

Method Detail

getRmiServer

RmiServer getRmiServer()

setRmiServer

void setRmiServer(RmiServer rmiServer)
           throws RemoteException

Throws:

RemoteException

registerWorker

void registerWorker(Worker worker)
             throws RemoteException

注册工人

Parameters:

worker -

Throws:

RemoteException

unregisterWorker

void unregisterWorker(Worker worker)
               throws RemoteException

注消工人

Parameters:

worker -

Throws:

RemoteException

getWorkQueue

WorkQueue getWorkQueue()

返回工作队列对象

Returns:

getWorkList

List<Work> getWorkList()
                throws RemoteException

返回所有的工作列表

Returns:

Throws:

RemoteException

getWorkerList

List<Worker> getWorkerList(Work work)
                    throws RemoteException

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

Returns:

Throws:

RemoteException

getWorkList

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

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

Returns:

Throws:

RemoteException

registerWork

void registerWork(Work work)
           throws IOException

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

Parameters:

work -

Throws:

IOException

unregisterWork

void unregisterWork(Work work)
             throws RemoteException

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

Parameters:

work -

Throws:

RemoteException

doWork

Warehouse doWork(Work work)
          throws IOException

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

Parameters:

work -

Throws:

IOException

getWorkStatus

WorkStatus getWorkStatus(Work work)
                  throws RemoteException

返回指定工作的工作状态

Parameters:

work -

Returns:

Throws:

RemoteException

registerForeman

void registerForeman(Foreman foreman)
              throws RemoteException

注册包工头

Parameters:

foreman -

Throws:

RemoteException

unregisterForeMan

void unregisterForeMan(Foreman foreman)
                throws RemoteException

注销包工头

Parameters:

foreman -

Throws:

RemoteException

getForeman

List<Foreman> getForeman(String type)
                  throws RemoteException

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

Parameters:

type -

Returns:

Throws:

RemoteException

autoMatch

void autoMatch()
        throws IOException

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

Throws:

IOException

stop

void stop()
   throws RemoteException

职业介绍所关门

Throws:

RemoteException