调度员，工人及任务的OO分析过程

package com.sitinspring.taskmanagement.domain; 
 
import com.sitinspring.taskmanagement.util.IdUtil; 
 
public class Task implements Comparable {
private String id; 
 
private String name; 
 
// 完成需消耗的工时数
private int manHour; 
 
// 已经完成的工时数
private int completed; 
 
// 优先级
private int priority; 
 
// 接受任务者
private Worker worker; 
 
// 发布任务者
private Attemper attemper; 
 
public Task(String name, int manHour) {
this(name, manHour, 0); 
}
 
public Task(String name, int manHour, int priority) {
id = IdUtil.generateId(); 
this.name = name; 
this.manHour = manHour; 
this.priority = priority; 
this.completed = 0; 
}
 
// 任务是否完成
public boolean isCompleted() {
return completed ＞= manHour; 
}
 
// 添加完成度
public void addCompleted(int n) {
completed += n; 
 
if (isCompleted()) {
completed = manHour; 
 
if (worker != null) {
// 完成后让工人把自己从任务列表中删除
worker.removeTask(this); 
}
 
if (attemper != null) {
// 完成后把任务添加到调度员(任务发送者)的完成任务链表
attemper.addCompletedTask(this); 
}
}
}
 
public int compareTo(Object obj) {
Task another = (Task) obj; 
return (another.priority) - this.priority; 
}
 
public String toString() {
return "任务名:" + name + " 工人名:" + worker.getName() + " 完成度:" + completed
* 100 / manHour + "%"; 
}
 
public int getCompleted() {
return completed; 
}
 
public void setCompleted(int completed) {
this.completed = completed; 
}
 
public int getManHour() {
return manHour; 
}
 
public void setManHour(int manHour) {
this.manHour = manHour; 
}
 
public String getName() {
return name; 
}
 
public void setName(String name) {
this.name = name; 
}
 
public String getId() {
return id; 
}
 
public int getPriority() {
return priority; 
}
 
public void setPriority(int priority) {
this.priority = priority; 
}
 
public Worker getWorker() {
return worker; 
}
 
public void setWorker(Worker worker) {
this.worker = worker; 
}
 
public Attemper getAttemper() {
return attemper; 
}
 
public void setAttemper(Attemper attemper) {
this.attemper = attemper; 
}
}
 

com.sitinspring.taskmanagement.domain; 
 
import java.util.Collections; 
import java.util.LinkedList; 
import java.util.List; 
 
public class TaskBunch{
// 任务链表
private List＜Task＞ tasks; 
 
public TaskBunch(){
tasks=new LinkedList＜Task＞(); 
}
 
// 取得最优先任务
public Task getTopTask(){
return tasks.get(0); 
}
 
// 取得任务个数
public int getSize(){
return tasks.size(); 
}
 
// 判断是否完成
public boolean isCompleted(){
for(Task task:tasks){
if(task.isCompleted()==false){
return false; 
}
}
 
return true; 
}
 
// 添加任务
public void addTask(Task task){
tasks.add(task); 
Collections.sort(tasks); 
}
 
// 删除任务
public void removeTask(Task task){
tasks.remove(task); 
}
}

package com.sitinspring.taskmanagement.domain; 
 
import com.sitinspring.taskmanagement.util.IdUtil; 
 
public class Worker implements Runnable{
private String id; 
private String name; 
 
// 任务列表
private TaskBunch taskBunch; 
 
// 工作速度
private int speed; 
 
public Worker(String name,int speed){
id=IdUtil.generateId(); 
this.name=name; 
this.speed=speed; 
taskBunch=new TaskBunch(); 
}
 
// 添加任务
public void addTask(Task task){
task.setWorker(this); 
taskBunch.addTask(task); 
}
 
// 删除任务
public void removeTask(Task task){
taskBunch.removeTask(task); 
}
 
// 开始干活
public void doWork(){
Thread thread=new Thread(this); 
thread.start(); 
}
 
// 真正干活
public void run(){
while(!taskBunch.isCompleted()){
try{
Thread.sleep(1000); 
Task task=taskBunch.getTopTask(); 
task.addCompleted(speed); 
System.out.println("正在处理的任务"+task+" 还需处理"+taskBunch.getSize()+"个."); 
}
catch(Exception ex){
ex.printStackTrace(); 
} 
}
 
System.out.println("工人"+name+"的全部任务处理完毕!"); 
}
 
public String getName() {
return name; 
}
public void setName(String name) {
this.name = name; 
}
public String getId() {
return id; 
} 
}
 
　　最后是调度员类,它的主要任务是生成任务以及管理已经完成的任务,代码比较简单:
 
package com.sitinspring.taskmanagement.domain; 
 
import com.sitinspring.taskmanagement.util.IdUtil; 
 
public class Attemper{
private String id; 
private String name; 
private TaskBunch completedTasks; 
 
public Attemper(String name){
id=IdUtil.generateId(); 
this.name=name; 
completedTasks=new TaskBunch(); 
}
 
public Task generateTask(String name,int manHour,int priority){
Task task=new Task(name,manHour,priority); 
task.setAttemper(this); 
return task; 
}
 
public void addCompletedTask(Task task){
completedTasks.addTask(task); 
}
 
public String getId() {
return id; 
}
 
public String getName() {
return name; 
}
}
 
具体示例执行过程如下:
 
Attemper Attemper=new Attemper("调度员"); 
 
Worker commonWorker=new Worker("普通工人一",2); 
commonWorker.addTask(Attemper.generateTask("任务1",8,1)); 
commonWorker.addTask(Attemper.generateTask("任务2",9,2)); 
commonWorker.addTask(Attemper.generateTask("任务3",20,3)); 
commonWorker.doWork(); 
 
Worker skilledWorker=new Worker("熟练工人二",3); 
skilledWorker.addTask(Attemper.generateTask("任务4",5,2)); 
skilledWorker.addTask(Attemper.generateTask("任务5",30,2)); 
skilledWorker.addTask(Attemper.generateTask("任务6",16,3)); 
skilledWorker.doWork(); 
 
Worker oldSkilledWorker=new Worker("老熟练工人三",5); 
oldSkilledWorker.addTask(Attemper.generateTask("任务7",15,2)); 
oldSkilledWorker.addTask(Attemper.generateTask("任务8",13,2)); 
oldSkilledWorker.addTask(Attemper.generateTask("任务9",7,3)); 
oldSkilledWorker.doWork();