黑马程序员技术交流社区

标题: 同步问题请教 [打印本页]

---

作者: doyxy    时间: 2014-3-14 21:30
标题: 同步问题请教


犯了低级错误,if把后面的东西全括进去了,晕死


看毕老师day12的视频,发现怎么改都运行不了,仔细查看了代码,和视频里的一样,,但是运行起来就是没有输出,空白的,实在是找不到哪里出问题了,请大家指点一下

1. public class ThreadCommunication {
   
2. 
   
3.         /*
   
4.          * 设计一个简单的多线程同时操作一个对象的例子,解决安全问题 创建两个线程,一个输入姓名性别,一个输出姓名性别;
   
5.          * 当输入没有完成时,有可能发生输出错误,需要解决; 输入与输出需要加锁 进一步的,想要输入数值后,等待输出完毕才继续输入,
   
6.          * 需要两个线程判断资源内是否有值,没有则输入然后等待,有则输出然后等待 两个线程间需要一个联系方式来互相通知
   
7.          */
   
8.         public static void main(String[] args) {
   
9.                 Res r = new Res();
   
10.                 InputDemo in = new InputDemo(r);
    
11.                 OutputDemo out = new OutputDemo(r);
    
12.                 Thread t1 = new Thread(in);
    
13.                 Thread t2 = new Thread(out);
    
14.                 t1.start();
    
15.                 t2.start();
    
16.         }
    
17. 
    
18. }
    
19. 
    
20. class Res {// 创建资源类
    
21.         String name;
    
22.         String sex;
    
23.         boolean flag=false; // 默认为false,表示目前没有资源;
    
24. }
    
25. 
    
26. class InputDemo implements Runnable {
    
27.         private Res r;
    
28. 
    
29.         InputDemo(Res r) {// 需要操作的是资源对象
    
30.                 this.r = r;
    
31.         }
    
32. 
    
33.         public void run() {// 操作方法,打印
    
34.                 int x=0;
    
35.                 while (true) {
    
36.                         synchronized (r) {
    
37.                                 if (r.flag) {
    
38.                                         try {r.wait();} catch (InterruptedException e) {}
    
39.                                         if (x==0) {
    
40.                                                 r.name = "name";
    
41.                                                 r.sex = "sex";
    
42.                                         } else {
    
43.                                                 r.name = "姓名";
    
44.                                                 r.sex = "性别";
    
45.                                         }
    
46.                                         x=(x+1)%2;
    
47.                                         r.flag = true;
    
48.                                         r.notify();
    
49.                                 }
    
50.                         }
    
51.                 }
    
52.         }
    
53. 
    
54. }
    
55. 
    
56. class OutputDemo implements Runnable {
    
57. 
    
58.         private Res r;
    
59. 
    
60.         OutputDemo(Res r) {// 需要操作的是资源对象
    
61.                 this.r = r;
    
62.         }
    
63. 
    
64.         public void run() {
    
65. 
    
66.                 while (true) {
    
67.                         synchronized (r) {
    
68.                                 if (!r.flag) {
    
69.                                         try {r.wait();} catch (InterruptedException e) {}
    
70.                                         System.out.println(r.name + "---" + r.sex);
    
71.                                         r.flag = false;
    
72.                                         r.notify();
    
73.                                 }
    
74.                         }
    
75.                 }
    
76.         }
    
77. 
    
78. }

复制代码

---

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

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