在MainClass类中，
new Runnable(){
public void run(){
Integer serviceNumber = NumberMachine.getInstance().getCommonManager().generateNewNumber();
System.out.println("第" + serviceNumber + "号普通客户正在等待服务！");
}
},
0,
Constants.COMMON_CUSTOMER_INTERVAL_TIME,
TimeUnit.SECONDS);
这两段代码 Integer serviceNumber = NumberMachine.getInstance().getCommonManager().generateNewNumber();
System.out.println("第" + serviceNumber + "号普通客户正在等待服务！");
不具有原子性所以在运行过程中可能会出现，xx客户已经被服务了，还打印xx客户正在等待服务的情况，如下运行结果：
..........................................................................................
第3号普通窗口开始为第4号普通客户服务
第2号普通窗口开始获取普通任务!
第2号普通窗口开始为第5号普通客户服务
第4号普通窗口开始获取普通任务!
第4号普通窗口没有取到普通任务，正在空闲一秒
第5号普通客户正在等待服务！
.........................................................................................
于是我对源代码进行了一些改进，来避免出现这种服务了还在等待的情况，
改进如下：
//普通客户拿号
Executors.newScheduledThreadPool(1).scheduleAtFixedRate(
new Runnable(){
public void run(){
// Integer serviceNumber = NumberMachine.getInstance().getCommonManager().generateNewNumber();
// System.out.println("第" + serviceNumber + "号普通客户正在等待服务！");
NumberMachine.getInstance().getCommonManager().generateNewNumber();
}
},
0,
Constants.COMMON_CUSTOMER_INTERVAL_TIME,
TimeUnit.SECONDS);
//快速客户拿号
Executors.newScheduledThreadPool(1).scheduleAtFixedRate(
new Runnable(){
public void run(){
// Integer serviceNumber = NumberMachine.getInstance().getExpressManager().generateNewNumber();
// System.out.println("第" + serviceNumber + "号快速客户正在等待服务！");
NumberMachine.getInstance().getExpressManager().generateNewNumber();
}
},
0,
Constants.COMMON_CUSTOMER_INTERVAL_TIME * 2,
TimeUnit.SECONDS);
//VIP客户拿号
Executors.newScheduledThreadPool(1).scheduleAtFixedRate(
new Runnable(){
public void run(){
// Integer serviceNumber = NumberMachine.getInstance().getVipManager().generateNewNumber();
// System.out.println("第" + serviceNumber + "号VIP客户正在等待服务！");
NumberMachine.getInstance().getVipManager().generateNewNumber();
}
},
0,
Constants.COMMON_CUSTOMER_INTERVAL_TIME * 6,
TimeUnit.SECONDS);
}
public class NumberManager {
private int lastNumber = 0;
private List<Integer> queueNumbers = new ArrayList<Integer>();
private String userType=null;
public NumberManager(String userType){ this.userType= userType; }
/*
public synchronized Integer generateNewNumber(){
queueNumbers.add(++lastNumber);
return lastNumber;
}
*/
public synchronized void generateNewNumber(){
queueNumbers.add(++lastNumber);
System.out.println("第" + lastNumber + "号"+userType+"正在等待服务！");
}
public synchronized Integer fetchNumber(){
if(queueNumbers.size()>0){
return (Integer)queueNumbers.remove(0);
}else{
return null;
}
}
}
也就是在类 MainClass 和类NumberManager中将注释部分代码换成粗体部分代码。 |
收藏
淘帖
踩
