黑马程序员技术交流社区

标题: 模拟银行叫号系统的问题 [打印本页]
作者: 党巾水    时间: 2012-7-23 09:55
标题: 模拟银行叫号系统的问题
本帖最后由 刘馨琪 于 2012-8-14 16:17 编辑



我在做银行系统的时候出现图中标蓝的情况，我希望这里应该出现获取任务后来了客户应该就可以取到任务，我觉得可能是线程同步的问题，可又不知道怎么改，请问怎么办？谢谢
下面贴出部分代码，我认为可能需要做分析的部分。

代码如下：
主程序：
  1. import java.util.concurrent.Executors;
  2. import java.util.concurrent.TimeUnit;

  4. public class MainClass {
  5.         public static void main(String[] args){
  6.                 for (int i = 1; i < 5; i++) {
  7.                         ServiceWindow commonWindow = new ServiceWindow();
  8.                         commonWindow.setWindowID(i);
  9.                         commonWindow.start();
  10.                 }
  11.                
  12.                 ServiceWindow expressWindow = new ServiceWindow();
  13.                 expressWindow.setType(CustomerType.EXPRESS);
  14.                 expressWindow.setWindowID(1);
  15.                 expressWindow.start();
  16.                
  17.                 ServiceWindow vipWindow = new ServiceWindow();
  18.                 vipWindow.setType(CustomerType.VIP);
  19.                 vipWindow.setWindowID(1);
  20.                 vipWindow.start();
  21.                
  22.                 Executors.newScheduledThreadPool(1).scheduleAtFixedRate(
  23.                                 new Runnable(){
  24.                                         public void run() {
  25.                                                 Integer number = NumberMachine.getInsance().getCommonManger().generateNewNumber();
  26.                                                 System.out.println(number + "号普通客户在等待服务");
  27.                                         }
  28.                                        
  29.                                 },
  30.                                 0,
  31.                                 Constants.COMMON_CUSTOMER_INTERVAL_TIME,
  32.                                 TimeUnit.SECONDS);
  33.                
  34.                 Executors.newScheduledThreadPool(1).scheduleAtFixedRate(
  35.                                 new Runnable(){
  36.                                         public void run() {
  37.                                                 Integer number = NumberMachine.getInsance().getExpressManger().generateNewNumber();
  38.                                                 System.out.println(number + "号快速客户在等待服务");
  39.                                         }
  40.                                        
  41.                                 },
  42.                                 0,
  43.                                 Constants.EXPRESS_CUSTOMER_INTERVAL_TIME,
  44.                                 TimeUnit.SECONDS);
  45.                
  46.                 Executors.newScheduledThreadPool(1).scheduleAtFixedRate(
  47.                                 new Runnable(){
  48.                                         public void run() {
  49.                                                 Integer number = NumberMachine.getInsance().getVipManger().generateNewNumber();
  50.                                                 System.out.println(number + "号VIP客户在等待服务");        
  51.                                         }
  52.                                        
  53.                                 },
  54.                                 0,
  55.                                 Constants.VIP_CUSTOMER_INTERVAL_TIME,
  56.                                 TimeUnit.SECONDS);
  57.         }
  58. }
复制代码

复制代码
下面这段是叫号机管理系统：
  1. import java.util.ArrayList;
  2. import java.util.List;

  4. public class NumberManger {
  5.         private int lastNumber = 1;
  6.         private List<Integer> queueNumber = new ArrayList<Integer>();
  7.         
  8.         public synchronized Integer generateNewNumber(){
  9.                 queueNumber.add(lastNumber);
  10.                 return lastNumber++;
  11.         }
  12.         
  13.         public synchronized Integer fetchServiceNumber(){
  14.                 Integer number = null;
  15.                 if(queueNumber.size() > 0){
  16.                         number = queueNumber.remove(0);
  17.                 }
  18.                 return number;
  19.         }
  20. }
复制代码
作者: 党巾水    时间: 2012-7-26 13:38
没有人解答乎?
来自：黑马程序员训练营论坛 Android客户端
作者: 党巾水    时间: 2012-7-27 09:53
成了死贴？
作者: 王渠    时间: 2012-7-27 17:08
本帖最后由 王渠 于 2012-7-27 17:28 编辑
  1. import java.util.ArrayList;
  2. import java.util.List;

  4. public class NumberManger {
  5.         private int lastNumber = 1;
  6.         private List<Integer> queueNumber = new ArrayList<Integer>();
  7.         
  8.         public synchronized Integer generateNewNumber(){
  9.                 queueNumber.add(lastNumber);
  10.                 return lastNumber++;
  11.         }
  12.         
  13.         public synchronized Integer fetchServiceNumber(){
  14.                 Integer number = null;
  15.                 if(queueNumber.size() > 0){
  16.                         number = queueNumber.remove(0);
  17.                 }
  18.                 return number;
  19.         }
  20. }
复制代码
上面是产生用户，和消亡用户的两个同步的方法。保证了多线程时，不会出现安全问题。
import java.util.Random;
import java.util.concurrent.Executors;

public class ServiceWindow {
        public void setType(CustomerType type) {
                this.type = type;
        }

        public void setWindowID(int windowID) {
                this.windowID = windowID;
        }

        private CustomerType type = CustomerType.COMMON;
        private int windowID = 1;
        
        public void start(){
                Executors.newSingleThreadExecutor().execute(new Runnable(){
                        public void run(){
                                while (true) {
switch (type) {
                                        case COMMON:
                                                commonService();
                                                break;
                                        case EXPRESS:
                                                expressService();
                                                break;
                                        case VIP:
                                                vipService();
                                                break;
                                        }
                                }
                        }
                });               
        }
private void commonService() {
                String windowName ="第" + windowID + "号" + type + "窗口";                                                
                Integer number = NumberMachine.getInsance().getCommonManger().fetchServiceNumber();//这里用到了同步的方法，无论值是否为null，都会输出下面的话。线程对应窗口输出了下面的话。
                System.out.println(windowName + "正在获取任务");               
               
                if (number != null) {//此时第一个用户还没有进来，判断为false。
                        System.out.println(windowName + "为第" + number +"个" + "普通客户服务中………………!");
                        long beginTime = System.currentTimeMillis();
                        int maxRand = Constants.Max_Service_Time - Constants.Min_Service_Time;
                        long serveTime = new Random().nextInt(maxRand + 1) + Constants.Min_Service_Time;
                        try {
                                Thread.sleep(serveTime);
                        } catch (InterruptedException e) {
                                e.printStackTrace();
                        }
                        long costTime = System.currentTimeMillis()-beginTime;
                        System.out.println(windowName + "为第" + number +"个" + "普通客户完成服务，耗时" + costTime/1000 + "秒");
                } else {
                        System.out.println(windowName + "没有取到任务，正在休息1秒……");//判断到用户数量为0了，正准备打印这句话，挂上了。进入阻塞了。同时，1号用户产生了，并打印了1号用户在等待的话，该线程才获取到cpu执行权，开始被执行，打印了这句话。出现了蓝色部分的情况，是正常的现象。
                        try {
                                Thread.sleep(1000);
                        } catch (InterruptedException e) {
                                e.printStackTrace();
                        }
                }
        }
        
        private void expressService() {
                String windowName ="第" + windowID + "号" + type + "窗口";                                                                                       
                Integer number = NumberMachine.getInsance().getExpressManger().fetchServiceNumber();
                System.out.println(windowName + "正在获取任务");        
               
                if (number != null) {
                        System.out.println(windowName + "为第" + number +"个" +type + "客户服务中………………!");
                        long beginTime = System.currentTimeMillis();
                        //int maxRand = Constants.Max_Service_Time - Constants.Min_Service_Time;
                        //long serveTime = new Random().nextInt(maxRand) + 1 + Constants.Min_Service_Time;
                        try {
                                Thread.sleep(Constants.Min_Service_Time);
                        } catch (InterruptedException e) {
                                e.printStackTrace();
                        }
                        long costTime = System.currentTimeMillis()-beginTime;
                        System.out.println(windowName + "为第" + number +"个" +type + "客户完成服务，耗时" + costTime/1000 + "秒");
                } else {
                        System.out.println(windowName + "没有取到任务");
                        commonService();
                }
        }
        
        private void vipService() {
                String windowName ="第" + windowID + "号" + type + "窗口";                                                                                
                Integer number = NumberMachine.getInsance().getVipManger().fetchServiceNumber();
                System.out.println(windowName + "正在获取任务");               
               
                if (number != null) {
                        System.out.println(windowName + "为第" + number +"个" +type + "客户服务中………………!");
                        long beginTime = System.currentTimeMillis();
                        int maxRand = Constants.Max_Service_Time - Constants.Min_Service_Time;
                        long serveTime = new Random().nextInt(maxRand + 1) + Constants.Min_Service_Time;
                        try {
                                Thread.sleep(serveTime);
                        } catch (InterruptedException e) {
                                e.printStackTrace();
                        }
                        long costTime = System.currentTimeMillis()-beginTime;
                        System.out.println(windowName + "为第" + number +"个" +type + "客户完成服务，耗时" + costTime/1000 + "秒");
                } else {
                        System.out.println(windowName + "没有取到任务");
                        commonService();
                }
        }
}
作者: 党巾水    时间: 2012-8-7 14:47
王渠 发表于 2012-7-27 17:08
上面是产生用户，和消亡用户的两个同步的方法。保证了多线程时，不会出现安全问题。
import java.util.Rand ...

谢谢啦！我好好看一下



欢迎光临 黑马程序员技术交流社区 (http://bbs.itheima.com/) 黑马程序员IT技术论坛 X3.2