模拟银行叫号系统的问题

蒋映辉

本帖最后由刘馨琪于 2012-8-14 16:17 编辑

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

代码如下：
主程序：

import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;
public class MainClass {
public static void main(String[] args){
for (int i = 1; i < 5; i++) {
ServiceWindow commonWindow = new ServiceWindow();
commonWindow.setWindowID(i);
commonWindow.start();
}
ServiceWindow expressWindow = new ServiceWindow();
expressWindow.setType(CustomerType.EXPRESS);
expressWindow.setWindowID(1);
expressWindow.start();
ServiceWindow vipWindow = new ServiceWindow();
vipWindow.setType(CustomerType.VIP);
vipWindow.setWindowID(1);
vipWindow.start();
Executors.newScheduledThreadPool(1).scheduleAtFixedRate(
new Runnable(){
public void run() {
Integer number = NumberMachine.getInsance().getCommonManger().generateNewNumber();
System.out.println(number + "号普通客户在等待服务");
}
},
0,
Constants.COMMON_CUSTOMER_INTERVAL_TIME,
TimeUnit.SECONDS);
Executors.newScheduledThreadPool(1).scheduleAtFixedRate(
new Runnable(){
public void run() {
Integer number = NumberMachine.getInsance().getExpressManger().generateNewNumber();
System.out.println(number + "号快速客户在等待服务");
}
},
0,
Constants.EXPRESS_CUSTOMER_INTERVAL_TIME,
TimeUnit.SECONDS);
Executors.newScheduledThreadPool(1).scheduleAtFixedRate(
new Runnable(){
public void run() {
Integer number = NumberMachine.getInsance().getVipManger().generateNewNumber();
System.out.println(number + "号VIP客户在等待服务");
}
},
0,
Constants.VIP_CUSTOMER_INTERVAL_TIME,
TimeUnit.SECONDS);
}
}

复制代码

下面这段是叫号机管理系统：

import java.util.ArrayList;
import java.util.List;
public class NumberManger {
private int lastNumber = 1;
private List<Integer> queueNumber = new ArrayList<Integer>();
public synchronized Integer generateNewNumber(){
queueNumber.add(lastNumber);
return lastNumber++;
}
public synchronized Integer fetchServiceNumber(){
Integer number = null;
if(queueNumber.size() > 0){
number = queueNumber.remove(0);
}
return number;
}
}

复制代码

党巾水 · 党巾水

没有人解答乎?
来自：黑马程序员训练营论坛 Android客户端来自: Android客户端

党巾水 · 党巾水

成了死贴？

王渠 · 王渠

本帖最后由王渠于 2012-7-27 17:28 编辑

import java.util.ArrayList;
import java.util.List;
public class NumberManger {
private int lastNumber = 1;
private List<Integer> queueNumber = new ArrayList<Integer>();
public synchronized Integer generateNewNumber(){
queueNumber.add(lastNumber);
return lastNumber++;
}
public synchronized Integer fetchServiceNumber(){
Integer number = null;
if(queueNumber.size() > 0){
number = queueNumber.remove(0);
}
return number;
}
}

复制代码

上面是产生用户，和消亡用户的两个同步的方法。保证了多线程时，不会出现安全问题。
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-7-27 17:08
上面是产生用户，和消亡用户的两个同步的方法。保证了多线程时，不会出现安全问题。
import java.util.Rand ...

谢谢啦！我好好看一下

帐号		自动登录	找回密码
密码			加入黑马

模拟银行叫号系统的问题

评分

4 个回复