黑马程序员技术交流社区

标题: 关于多线程卖票程序问题 [打印本页]

---

作者: breeze    时间: 2013-5-29 13:34
标题: 关于多线程卖票程序问题


程序是将卖票的票, 卖票窗口, 售票中心 分别定义成类来实现的, 但是我的运行结果的中前四个售出的票出现了相同的号码, 请大家帮我看一下是哪里出了问题

1. package com.itheima.exam;
   
2. 
   
3. public class Test19 {
   
4.         int x = 1;
   
5.         public static void main(String[] args) {
   
6.                 new TicketSealCenter();
   
7.         
   
8.         }
   
9. }
   
10. //定义票的类
    
11. class Ticket {
    
12.         int ticketNumber = 1;
    
13.         
    
14.         public int getTiket() {
    
15.                 return ticketNumber++;
    
16.         }
    
17. }
    
18. //定义卖票窗口的类
    
19. class SealWindow {
    
20.         Ticket ticket = new Ticket();
    
21.         
    
22.         public synchronized int sealTicket() {
    
23.                 return ticket.getTiket();
    
24.         }
    
25. }
    
26. //定义售票中心的类
    
27. class TicketSealCenter {
    
28.         
    
29.         int totalTicket = 100;
    
30.         SealWindow sealWindow = new SealWindow();
    
31.         int totalWindow = 4;
    
32.         int windowId = 1;
    
33.         int ticket = 1;
    
34.         
    
35.         public TicketSealCenter() {
    
36.                 while (windowId <= totalWindow) {
    
37.                         //开启线程
    
38.                         new Thread() {
    
39.                                 //得到窗口ID
    
40.                                 int windowId = TicketSealCenter.this.windowId++;
    
41.                                 public void run() {
    
42.                                         try {
    
43.                                                 Thread.sleep(1);
    
44.                                         } catch (InterruptedException e) {
    
45.                                                 e.printStackTrace();
    
46.                                         }
    
47.                                         while (true) {
    
48.                                                 ticket = sealWindow.sealTicket();
    
49.                                                 if (ticket > totalTicket)
    
50.                                                         System.exit(0);
    
51.                                                 System.out.println(windowId + "窗口卖了" + ticket + "号票");
    
52.                                         }
    
53.                                 }
    
54.                         }.start();
    
55.                 }
    
56.         }
    
57. }

复制代码

---

作者: Neverbelazy    时间: 2013-5-29 14:05


打印也需要是同步的操作， 否则, 假设

窗口1sealTicket(....sellTicket)买票--->挂起；  ticket=10;
窗口2sealTicket——>挂起; ticket=11;
窗口3sealTicket——>挂起; ticket=12;
窗口4sealTicket——>挂起；ticket=13;
此时, 窗口1-4依次继续向下执行, 每个线程都执行到刚好打印结束才切换到下一个线程
打印的票就是:
1窗口13；
2窗口13；
3窗口13；
4窗口13；

程序中windowID最好是sealWindow的成员, 这样更合理, 而且会对之后修改同步代码很方便

请参考

---

作者: breeze    时间: 2013-5-29 16:22

Neverbelazy 发表于 2013-5-29 14:05
打印也需要是同步的操作， 否则, 假设

窗口1sealTicket(....sellTicket)买票--->挂起；  ticket=10;

这样岂不是容易造成死锁, 获取的 ticket是在线程内部的run方法定义的, 它怎么会改变呢

---

作者: Neverbelazy    时间: 2013-5-29 16:51

breeze 发表于 2013-5-29 16:22
这样岂不是容易造成死锁, 获取的 ticket是在线程内部的run方法定义的, 它怎么会改变呢 ...

1. ticket是你用sealWindow.sealTicket得到的 除了这一步是同步外, 其他部分都没有同步
2. 你指的死锁应该是 嵌套了 synchronized(){ sealTicket()} 但是, 如果 synchronized(){}这个整体就不用再 将 sealTicket 标记为synchronized了
3. 另外,
while(true){
   //我的经验是，这行最好加一句Thread.sleep(xxx); 否则一个线程抢到执行权不放, 自己无限循环
   synchromized(xxx){
   // 同步代码
   }
}

---

作者: 吴刚—heima    时间: 2013-5-29 16:52
我在控制台测试一下你的代码没有问题呀，你出现问题是不是因为运行环境的问题，下面是我运行结果截图

1.png (4.29 KB, 下载次数: 0)

下载附件

2013-5-29 16:52 上传

---

作者: Neverbelazy    时间: 2013-5-29 16:55

吴刚—heima 发表于 2013-5-29 16:52
我在控制台测试一下你的代码没有问题呀，你出现问题是不是因为运行环境的问题，下面是我运行结果截图 ...

......
......
while(true){
ticket=sealWindow.sealTicket();
//在这个之后加一句 try{Thread.sleep(10)}catch(Exception e){};
....
....
}

之后就能看到重复票了

---

作者: Neverbelazy    时间: 2013-5-29 16:55

吴刚—heima 发表于 2013-5-29 16:52
我在控制台测试一下你的代码没有问题呀，你出现问题是不是因为运行环境的问题，下面是我运行结果截图 ...

......
......
while(true){
ticket=sealWindow.sealTicket();
//在这个之后加一句 try{Thread.sleep(10);}catch(Exception e){};
....
....
}

之后就能看到重复票了

---

作者: 吴刚—heima    时间: 2013-5-29 16:59
  //开启线程
                        new Thread() {
                                //得到窗口ID
                                int windowId = TicketSealCenter.this.windowId++;
                                public void run() {
                                        try {
                                                Thread.sleep(1);
                                        } catch (InterruptedException e) {
                                                e.printStackTrace();
                                        }
                                        while (true) {
                                                ticket = sealWindow.sealTicket();
                                                if (ticket > totalTicket)
                                                        System.exit(0);
                                                System.out.println(windowId + "窗口卖了" + ticket + "号票");
                                        }
                                }
                        }.start();

如果还是不能得到我这个结果，我建议你将这一段加上synchronized 监听一下，你这段代码会产生四个线程，但是这四个线程却没有加上监听，所以还是可能会产生线程异步的情况。

---

作者: Neverbelazy    时间: 2013-5-29 17:07


Breeze, 我知道你的意思了，

在你这个程序中只要 变成 int ticket=sealWindow.sealTicket(); 变成局部变量程序就可以正常运行了,
之前，你里面的ticket是一直在重复为成员的ticket赋值；而成员ticket是这几个Thread共有的

更好的写法是 换个名称 int piao=sealWindow.sealTicket()； 这样就没有歧义了

---

作者: breeze    时间: 2013-5-30 16:50

Neverbelazy 发表于 2013-5-29 17:07
Breeze, 我知道你的意思了，

在你这个程序中只要 变成 int ticket=sealWindow.sealTicket(); 变成局部变 ...

就是这个原因, 谢谢你可以仔细看我的代码, 能不能留个你的联系方式, 有问题可以随时讨论

---

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

黑马程序员IT技术论坛 X3.2