org.tinygroup.tinypc.impl

Class WorkQueueImpl

java.lang.Object

org.tinygroup.tinypc.impl.WorkQueueImpl

All Implemented Interfaces:

Serializable, Remote, RemoteObject, WorkQueue

public class WorkQueueImpl
extends Object
implements WorkQueue

Created by luoguo on 14-1-23.

See Also:

Serialized Form

Field Summary

Fields inherited from interface org.tinygroup.tinypc.WorkQueue

WORKQUEUE_TYPE

Constructor Summary

Constructors

Constructor and Description
WorkQueueImpl()

Method Summary

Modifier and Type	Method and Description
void	add(Work work) 添加一个工作
Work	getIdleWork() 返回一个空闲工作
ObjectStorage	getObjectStorage()
List<Work>	getWorkList() 返回所有的工作列表
List<Work>	getWorkList(String type, WorkStatus workStatus) 返回指定类型指定工作状态的工作列表
List<Work>	getWorkList(WorkStatus workStatus) 返回指定工作状态的工作列表
WorkStatus	getWorkStatus(Work work) 获取工作状态
void	moveToLast(Work work) 把工作移动到工作队列最后
void	remove(Work work) 删除一个工作
void	replace(Work oldWork, Work newWork) 去掉一个旧工作，添加一个新工作
void	setObjectStorage(ObjectStorage objectStorage) 设置对象仓库
int	size() 返回工作总数
void	updateWorkStatus(Work work, WorkStatus workStatus) 更新工作状态

Methods inherited from class java.lang.Object

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

Constructor Detail

WorkQueueImpl

public WorkQueueImpl()
              throws RemoteException

Throws:

RemoteException

Method Detail

getObjectStorage

public ObjectStorage getObjectStorage()

setObjectStorage

public void setObjectStorage(ObjectStorage objectStorage)

Description copied from interface: WorkQueue

设置对象仓库

Specified by:

setObjectStorage in interface WorkQueue

add

public void add(Work work)
         throws RemoteException

Description copied from interface: WorkQueue

添加一个工作

Specified by:

add in interface WorkQueue

Throws:

RemoteException

updateWorkStatus

public void updateWorkStatus(Work work,
                             WorkStatus workStatus)
                      throws RemoteException

Description copied from interface: WorkQueue

更新工作状态

Specified by:

updateWorkStatus in interface WorkQueue

Throws:

RemoteException

getWorkStatus

public WorkStatus getWorkStatus(Work work)
                         throws RemoteException

Description copied from interface: WorkQueue

获取工作状态

Specified by:

getWorkStatus in interface WorkQueue

Returns:

Throws:

RemoteException

remove

public void remove(Work work)
            throws RemoteException

Description copied from interface: WorkQueue

删除一个工作

Specified by:

remove in interface WorkQueue

Throws:

RemoteException

size

public int size()
         throws RemoteException

Description copied from interface: WorkQueue

返回工作总数

Specified by:

size in interface WorkQueue

Returns:

Throws:

RemoteException

getWorkList

public List<Work> getWorkList()
                       throws RemoteException

Description copied from interface: WorkQueue

返回所有的工作列表

Specified by:

getWorkList in interface WorkQueue

Returns:

Throws:

RemoteException

getIdleWork

public Work getIdleWork()
                 throws RemoteException

Description copied from interface: WorkQueue

返回一个空闲工作

Specified by:

getIdleWork in interface WorkQueue

Returns:

Throws:

RemoteException

getWorkList

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

Description copied from interface: WorkQueue

返回指定类型指定工作状态的工作列表

Specified by:

getWorkList in interface WorkQueue

Returns:

getWorkList

public List<Work> getWorkList(WorkStatus workStatus)

Description copied from interface: WorkQueue

返回指定工作状态的工作列表

Specified by:

getWorkList in interface WorkQueue

Returns:

replace

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

Description copied from interface: WorkQueue

去掉一个旧工作，添加一个新工作

Specified by:

replace in interface WorkQueue

Throws:

RemoteException

moveToLast

public void moveToLast(Work work)

Description copied from interface: WorkQueue

把工作移动到工作队列最后

Specified by:

moveToLast in interface WorkQueue