黑马程序员技术交流社区

标题: 线程同步问题，两线程交替打印，连续的三个A，B。代码如下 [打印本页]

---

作者: 丸子    时间: 2014-8-6 17:07
标题: 线程同步问题，两线程交替打印，连续的三个A，B。代码如下


public class ThreadExample {

        /**
         * @param args
         */
        public static void main(String[] args) {
                // TODO Auto-generated method stub
                final Service1 s=new Service1();
   
                Thread t1=new Thread(){
                        public void run(){
                                for(int i=0;i<7;i++){
                                        s.print1();
                                        try {
                                                Thread.sleep(1000);
                                        } catch (InterruptedException e) {
                                                // TODO Auto-generated catch block
                                                e.printStackTrace();
                                        }

                                }

                        }
                        
        
                };
                Thread t2=new Thread(){
                        public void run(){
                                for(int i=0;i<7;i++){
                                        s.print2();
                                        try {
                                                Thread.sleep(1000);
                                        } catch (InterruptedException e) {
                                                // TODO Auto-generated catch block
                                                e.printStackTrace();
                                        }
                                }
                                
                        }

                };
                t1.start();
                t2.start();
        }

}
class Service1 {
        int ss=0;
        public void print1(){
                if(ss!=0)
                        try {
                                this.wait();
                        } catch (InterruptedException e) {
                                // TODO Auto-generated catch block
                                e.printStackTrace();
                        }
                synchronized(this){
                        
                        for(int i=0;i<3;i++)
                                System.out.println(Thread.currentThread().getName()+"A");
                        System.out.println();
                        
                        }
                ss=1;
                this.notify();
        }
        public  void print2(){
                if(ss!=1)
                        try {
                                this.wait();
                        } catch (InterruptedException e) {
                                // TODO Auto-generated catch block
                                e.printStackTrace();
                        }
                synchronized(this){
                        
                        for(int i=0;i<3;i++)
                                System.out.println(Thread.currentThread().getName()+"B");
                        System.out.println();
                        
                        }
                ss=0;
                this.notify();
        }
}

---

作者: 丸子    时间: 2014-8-6 17:08
为什么出错？

---

作者: 萍水相逢    时间: 2014-8-6 18:34
改过后的代码：

1. public class ThreadExample {
   
2. 
   
3.         public static void main(String[] args) {
   
4.                 final Service1 s = new Service1();
   
5. 
   
6.                 new Thread() {
   
7.                         public void run() {
   
8.                                 for (int i = 0; i < 7; i++) {
   
9.                                         s.print1();
   
10.                                         try {
    
11.                                                 Thread.sleep(1000);
    
12.                                         } catch (InterruptedException e) {
    
13.                                                 e.printStackTrace();
    
14.                                         }
    
15.                                 }
    
16.                         }
    
17.                 }.start();
    
18.                 new Thread() {
    
19.                         public void run() {
    
20.                                 for (int i = 0; i < 7; i++) {
    
21.                                         s.print2();
    
22.                                         try {
    
23.                                                 Thread.sleep(1000);
    
24.                                         } catch (InterruptedException e) {
    
25.                                                 e.printStackTrace();
    
26.                                         }
    
27.                                 }
    
28.                         }
    
29.                 }.start();
    
30. //                t1.start();
    
31. //                t2.start();
    
32.         }
    
33. }
    
34. 
    
35. class Service1 {
    
36.         int ss = 0;
    
37. 
    
38.         public synchronized void print1() {
    
39.                 if (ss != 0)
    
40.                         try {
    
41.                                 this.wait();
    
42.                         } catch (InterruptedException e) {
    
43.                                 e.printStackTrace();
    
44.                         }
    
45. //                synchronized (this) {
    
46.                         for (int i = 0; i < 3; i++)
    
47.                                 System.out.println(Thread.currentThread().getName() + "-A");
    
48.                         System.out.println();
    
49. //                }
    
50.                 ss = 1;
    
51.                 this.notify();
    
52.         }
    
53. 
    
54.         public synchronized void print2() {
    
55.                 if (ss != 1)
    
56.                         try {
    
57.                                 this.wait();
    
58.                         } catch (InterruptedException e) {
    
59.                                 e.printStackTrace();
    
60.                         }
    
61. //                synchronized (this) {
    
62.                         for (int i = 0; i < 3; i++)
    
63.                                 System.out.println(Thread.currentThread().getName() + "-B");
    
64.                         System.out.println();
    
65. //                }
    
66.                 ss = 0;
    
67.                 this.notify();
    
68.         }
    
69. }

复制代码

---

作者: 萍水相逢    时间: 2014-8-6 18:39

丸子 发表于 2014-8-6 17:08
为什么出错？

  原因是：在对某个对象上调用wait()方法进行线程等待（让其他竞争执行该代码的线程上锁）时，没有对该对象执行同步操作。

---

作者: 丸子    时间: 2014-8-6 19:00

萍水相逢 发表于 2014-8-6 18:39
原因是：在对某个对象上调用wait()方法进行线程等待（让其他竞争执行该代码的线程上锁）时，没有对该对 ...

还是不懂，为什么wait（）只能放在synchronized的里面，不能在外面呢？

---

作者: yqj    时间: 2014-8-6 19:26


看看这样也可以（把notify()放在同步代码块中）

1. package cn.test;
   
2. 
   
3. public class ThreadExample {
   
4. 
   
5.         /**
   
6.          * @param args
   
7.          */
   
8.         public static void main(String[] args) {
   
9.                 final Service1 s = new Service1();
   
10. 
    
11.                 Thread t1 = new Thread() {
    
12.                         public void run() {
    
13.                                 for (int i = 0; i < 7; i++) {
    
14.                                         s.print1();
    
15.                                         try {
    
16.                                                 Thread.sleep(1000);
    
17.                                         } catch (InterruptedException e) {
    
18.                                                 e.printStackTrace();
    
19.                                         }
    
20. 
    
21.                                 }
    
22. 
    
23.                         }
    
24. 
    
25.                 };
    
26.                 Thread t2 = new Thread() {
    
27.                         public void run() {
    
28.                                 for (int i = 0; i < 7; i++) {
    
29.                                         s.print2();
    
30.                                         try {
    
31.                                                 Thread.sleep(1000);
    
32.                                         } catch (InterruptedException e) {
    
33.                                                 e.printStackTrace();
    
34.                                         }
    
35.                                 }
    
36. 
    
37.                         }
    
38. 
    
39.                 };
    
40.                 t1.start();
    
41.                 t2.start();
    
42.         }
    
43. }
    
44. 
    
45. class Service1 {
    
46.         int ss = 0;
    
47. 
    
48.         public void print1() {
    
49.                 if (ss != 0)
    
50.                         try {
    
51.                                 this.wait();
    
52.                         } catch (InterruptedException e) {
    
53.                                 // TODO Auto-generated catch block
    
54.                                 e.printStackTrace();
    
55.                         }
    
56.                 synchronized (this) {
    
57. 
    
58.                         for (int i = 0; i < 3; i++)
    
59.                                 System.out.println(Thread.currentThread().getName() + "A");
    
60.                         System.out.println();
    
61. 
    
62.                         ss = 1;
    
63.                         this.notify();
    
64.                 }
    
65.         }
    
66. 
    
67.         public void print2() {
    
68.                 if (ss != 1)
    
69.                         try {
    
70.                                 this.wait();
    
71.                         } catch (InterruptedException e) {
    
72.                                 // TODO Auto-generated catch block
    
73.                                 e.printStackTrace();
    
74.                         }
    
75.                 synchronized (this) {
    
76. 
    
77.                         for (int i = 0; i < 3; i++)
    
78.                                 System.out.println(Thread.currentThread().getName() + "B");
    
79.                         System.out.println();
    
80. 
    
81.                         ss = 0;
    
82.                         this.notify();
    
83.                 }
    
84.         }
    
85. }
    

复制代码

原因：对于notify()方法，jdk的说明：解除那些在该对象上调用wait()方法的线程的阻塞状态。notify()方法只能在同步方法或同步块内部调用。如果当前线程不是对象所得持有者，该方法抛出一个java.lang.IllegalMonitorStateException 异常”

所以把notify()方法放在同步代码中就ok了。
不知道解释对否，希望对lz有帮助！

---

作者: 丸子    时间: 2014-8-6 19:58

yqj 发表于 2014-8-6 19:26
看看这样也可以（把notify()放在同步代码块中）

原因：对于notify()方法，jdk的说明：解除那些在该对象上 ...

我把你的代码复制过来还是有错！！

---

作者: yqj    时间: 2014-8-6 20:11
哦，刚刚只测了一遍，又多测了几遍真的有错，以前学的时候记得是多线程的时候记得是wait()和notify()方法要放在同步代码块中忘了，以为就放notify()行了，那就要wait();和notify();都放同步代码块中，又测试了几遍应该没问题了，再出错我就不知道了

---

作者: 这个夏天的芬芳    时间: 2014-8-6 20:14
{:2_31:}{:2_31:}{:2_31:}{:2_31:}{:2_31:}{:2_31:}

---

作者: 萍水相逢    时间: 2014-8-6 21:21

丸子 发表于 2014-8-6 19:00
还是不懂，为什么wait（）只能放在synchronized的里面，不能在外面呢？

我的理解是：因为synchronized (this)就是一把锁，如果wait()不放在锁里面，就会造成很多线程都堵塞在这里，但加上锁就不一样，只有一个线程再等待，这样才会安全！

---

作者: 丸子    时间: 2014-8-7 07:43

yqj 发表于 2014-8-6 20:11
哦，刚刚只测了一遍，又多测了几遍真的有错，以前学的时候记得是多线程的时候记得是wait()和notify()方法要 ...

好的，谢谢。费心了{:3_53:}

---

作者: 丸子    时间: 2014-8-7 07:45

萍水相逢 发表于 2014-8-6 21:21
我的理解是：因为synchronized (this)就是一把锁，如果wait()不放在锁里面，就会造成很多线程都堵塞在这 ...

哦，貌似理解了，非常感谢{:3_64:}

---

作者: 萍水相逢    时间: 2014-8-7 08:39

丸子 发表于 2014-8-7 07:45
哦，貌似理解了，非常感谢

不客气！其实帮助你的同时，自己也学到了不少东西！

---

作者: 小小菜鸟007    时间: 2014-8-7 09:20
线程同步，只能放在synchronized里面

---

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

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