黑马程序员技术交流社区

标题: 多线程中的通信问题、、、 [打印本页]
作者: yting_xmei1129    时间: 2013-9-25 23:32
标题: 多线程中的通信问题、、、
下面是代码--->
  1. package yting.day11.thread;

  3. public class ThreadCommunication {

  5.         public static void main(String[] args) {
  6.                 Resource r = new Resource();
  7.                 new Thread(new Input(r)).start();
  8.                 new Thread(new Output(r)).start();
  9.         }

  11. }

  13. class Resource {
  14.         String name;
  15.         String sex;
  16.         boolean flag = false;
  17. }

  19. class Input implements Runnable {
  20.         private Resource r;

  22.         public Input(Resource r) {
  23.                 super();
  24.                 this.r = r;
  25.         }

  27.         @Override
  28.         public void run() {
  29.                 int f = 0;
  30.                 while (true) {
  31.                         synchronized (r) {
  32.                                 if(r.flag){
  33.                                         try {
  34.                                                 wait();
  35.                                         } catch (InterruptedException e) {
  36.                                                 e.printStackTrace();
  37.                                         }
  38.                                 }
  39.                                 if (f == 0) {
  40.                                         r.name = "zhangsan";
  41.                                         r.sex = "男";
  42.                                 } else {
  43.                                         r.name = "lili";
  44.                                         r.sex = "女";
  45.                                 }
  46.                                 f = (f + 1) % 2;
  47.                                
  48.                                 r.flag = true;
  49.                                 notify();
  50.                         }
  51.                 }
  52.         }

  54. }

  56. class Output implements Runnable {
  57.         private Resource r;

  59.         public Output(Resource r) {
  60.                 super();
  61.                 this.r = r;
  62.         }

  64.         @Override
  65.         public void run() {
  66.                 while (true) {
  67.                         synchronized (r) {
  68.                                 if(!r.flag){
  69.                                         try {
  70.                                                 wait();
  71.                                         } catch (InterruptedException e) {
  72.                                                 e.printStackTrace();
  73.                                         }
  74.                                 }
  75.                                 System.out.println(r.name + "..." + r.sex);
  76.                                
  77.                                 r.flag = false;
  78.                                 notify();
  79.                         }
  80.                 }
  81.         }

  83. }
复制代码
下面是运行结果--->
  1. Exception in thread "Thread-0" zhangsan...男
  2. java.lang.IllegalMonitorStateException
  3.         at java.lang.Object.notify(Native Method)
  4.         at yting.day11.thread.Input.run(ThreadCommunication.java:49)
  5.         at java.lang.Thread.run(Thread.java:662)
  6. Exception in thread "Thread-1" java.lang.IllegalMonitorStateException
  7.         at java.lang.Object.notify(Native Method)
  8.         at yting.day11.thread.Output.run(ThreadCommunication.java:78)
  9.         at java.lang.Thread.run(Thread.java:662)
复制代码
一直抱这个异常，怎么回事啊？坐等大神指导、、、谢了先！
作者: 肖亚光    时间: 2013-9-27 15:33
synchronized (r)
既然你同步的是这个对象，你就应该调用这个对象的wait() notify()方法 去告知线程等待和唤醒
  1. package com.test;

  3. public class Demo1 {

  5.         public static void main(String[] args) {
  6.                 Resource r = new Resource();
  7.                 new Thread(new Input(r)).start();
  8.                 new Thread(new Output(r)).start();
  9.         }

  11. }

  13. class Resource extends Thread{
  14.         String name;
  15.         String sex;
  16.         boolean flag = false ;
  17.        
  18. }

  20. class Input extends Thread {
  21.         private Resource r;

  23.         public Input(Resource r) {
  24.                 super();
  25.                 this.r = r;
  26.         }

  28.         @Override
  29.         public void run() {
  30.                 int f = 0;
  31.                 while (true) {
  32.                         synchronized (r) {
  33.                                 if (r.flag) {
  34.                                         try {
  35.                                                 r.wait();
  36.                                         } catch (InterruptedException e) {
  37.                                                 e.printStackTrace();
  38.                                         }
  39.                                 }
  40.                                 if (f == 0) {
  41.                                         r.name = "zhangsan";
  42.                                         r.sex = "男";
  43.                                 } else {
  44.                                         r.name = "lili";
  45.                                         r.sex = "女";
  46.                                 }
  47.                                 f = (f + 1) % 2;

  49.                                 r.flag = true;
  50.                                 r.notify();
  51.                         }
  52.                 }
  53.         }

  55. }

  57. class Output extends Thread {
  58.         private Resource r;

  60.         public Output(Resource r) {
  61.                 super();
  62.                 this.r = r;
  63.         }

  65.         @Override
  66.         public void run() {
  67.                 while (true) {
  68.                         synchronized (r) {
  69.                                 if (!r.flag) {
  70.                                         try {
  71.                                                 r.wait();
  72.                                         } catch (InterruptedException e) {
  73.                                                 e.printStackTrace();
  74.                                         }
  75.                                 }
  76.                                 System.out.println(r.name + "..." + r.sex);

  78.                                 r.flag = false;
  79.                                 r.notify();
  80.                         }
  81.                 }
  82.         }

  84. }
复制代码
你试试
作者: yting_xmei1129    时间: 2013-9-27 15:36
肖亚光 发表于 2013-9-27 15:33
synchronized (r)
既然你同步的是这个对象，你就应该调用这个对象的wait() notify()方法 去告知线程等待和 ...

谢谢了，后来饿才发现弄错了呢！




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