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

本帖最后由丸子于 2014-8-28 11:02 编辑

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();
      }
}

丸子 · 丸子

为什么出错？

萍水相逢 · 萍水相逢

改过后的代码：

public class ThreadExample {
public static void main(String[] args) {
final Service1 s = new Service1();
new Thread() {
public void run() {
for (int i = 0; i < 7; i++) {
s.print1();
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}.start();
new Thread() {
public void run() {
for (int i = 0; i < 7; i++) {
s.print2();
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}.start();
// t1.start();
// t2.start();
}
}
class Service1 {
int ss = 0;
public synchronized void print1() {
if (ss != 0)
try {
this.wait();
} catch (InterruptedException e) {
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 synchronized void print2() {
if (ss != 1)
try {
this.wait();
} catch (InterruptedException e) {
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
为什么出错？

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

丸子 · 丸子

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

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

yqj · yqj

本帖最后由 yqj 于 2014-8-6 19:27 编辑

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

package cn.test;
public class ThreadExample {
/**
* @param args
*/
public static void main(String[] args) {
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) {
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) {
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();
}
}
}

复制代码

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

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

丸子 · 丸子

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

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

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

yqj · yqj

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

这个夏天的芬芳 · 这个夏天的芬芳

{:2_31:}{:2_31:}{:2_31:}{:2_31:}{:2_31:}{:2_31:}

萍水相逢 · 萍水相逢

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

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

丸子 · 丸子

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

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

丸子 · 丸子

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

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

萍水相逢 · 萍水相逢

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

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

小小菜鸟007 · 小小菜鸟007

线程同步，只能放在synchronized里面

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

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

13 个回复