黑马程序员技术交流社区

标题: 线程问题，只输出一次，就报异常，看看哪里出了错 [打印本页]
作者: android-liu    时间: 2015-3-13 16:07
标题: 线程问题，只输出一次，就报异常，看看哪里出了错
  1. package com.xiangying.thread;

  3. import javax.xml.transform.OutputKeys;

  5. public class ThreadSave {

  7.         /**
  8.          * @param args
  9.          */
  10.         public static void main(String[] args) {
  11.                 Thread t = new Thread(new Input());
  12.                 Thread t1 = new Thread(new Output());

  14.                 t.start();
  15.                 t1.start();

  17.         }

  19. }

  21. // 饿汉式单例设计模式设计学生类：只能有一个对象
  22. class Student {

  24.         private String name;
  25.         private String sex;
  26.         boolean flag = false;
  27.         private static Student stu = new Student();

  29.         private Student() {
  30.         };

  32.         public static Student getStudent() {
  33.                 return stu;

  35.         }

  37.         public String getName() {
  38.                 return name;
  39.         }

  41.         public void setName(String name) {
  42.                 this.name = name;
  43.         }

  45.         public String getSex() {
  46.                 return sex;
  47.         }

  49.         public void setSex(String sex) {
  50.                 this.sex = sex;
  51.         }

  53.         public static Student getStu() {
  54.                 return stu;
  55.         }

  57.         public static void setStu(Student stu) {
  58.                 Student.stu = stu;
  59.         }

  61. }

  63. // 设计存入数据线程
  64. class Input implements Runnable {
  65.         Student s = Student.getStudent();
  66.         int x = 0;

  68.         @Override
  69.         public void run() {
  70.                 while (true) {
  71.                         synchronized (s) {
  72.                                 if (s.flag)
  73.                                         try {
  74.                                                 s.wait();
  75.                                         } catch (InterruptedException e1) {
  76.                                                 // TODO Auto-generated catch block
  77.                                                 e1.printStackTrace();
  78.                                         }
  79.                                 if (x == 0) {
  80.                                         s.setName("张三");
  81.                                         try {
  82.                                                 Thread.sleep(10);
  83.                                         } catch (InterruptedException e) {
  84.                                                 // TODO Auto-generated catch block
  85.                                                 e.printStackTrace();
  86.                                         }
  87.                                         s.setSex("男");
  88.                                 } else {

  90.                                         s.setName("lili");
  91.                                         try {
  92.                                                 Thread.sleep(10);
  93.                                         } catch (InterruptedException e) {
  94.                                                 // TODO Auto-generated catch block
  95.                                                 e.printStackTrace();
  96.                                         }
  97.                                         s.setSex("nvnvnnvnvnvnnv");
  98.                                 }
  99.                         }
  100.                         x = (x + 1) % 2;
  101.                         s.flag = true;
  102.                         s.notify();
  103.                 }
  104.         }
  105. }

  107. // 设计输出线程
  108. class Output implements Runnable {
  109.         Student s = Student.getStudent();

  111.         @Override
  112.         public void run() {
  113.                 while (true)
  114.                         synchronized (s) {
  115.                                 if (!s.flag)
  116.                                         try {
  117.                                                 s.wait();
  118.                                         } catch (InterruptedException e) {
  119.                                                 // TODO Auto-generated catch block
  120.                                                 e.printStackTrace();
  121.                                         }
  122.                                 System.out.println(s.getName() + "-----" + s.getSex());
  123.                                 s.flag = false;
  124.                                 notify();
  125.                         }

  127.         }

  129. }
复制代码
作者: sh1tge    时间: 2015-3-13 22:08
说几个明显的错误;
第一是你获取学生对象的时机不对
第二Input 类中 部分代码应该写进同步代码中 而你没有
第三output类中 notify 应该为 s.notify
第四while 循环少了个{

总之lz写代码的条理性有点乱...

顺便附上修改过后的
  1. public class ThreadSave {

  3.         /**
  4.          * @param args
  5.          */
  6.         public static void main(String[] args) {
  7.                         Student s = Student.getStudent();
  8.                 Thread t = new Thread(new Input(s));
  9.                 Thread t1 = new Thread(new Output(s));

  11.                 t.start();
  12.                 t1.start();

  14.         }

  16. }

  18. // 饿汉式单例设计模式设计学生类：只能有一个对象
  19. class Student {

  21.         private String name;
  22.         private String sex;
  23.         boolean flag = false;
  24.         private  static final Student stu = new Student();

  26.         private Student() {
  27.         }

  29.         public static Student getStudent() {
  30.                 return stu;

  32.         }

  34.         public String getName() {
  35.                 return name;
  36.         }

  38.         public void setName(String name) {
  39.                 this.name = name;
  40.         }

  42.         public String getSex() {
  43.                 return sex;
  44.         }

  46.         public void setSex(String sex) {
  47.                 this.sex = sex;
  48.         }

  50.      

  52. }

  54. // 设计存入数据线程
  55. class Input implements Runnable {
  56.         private Student s;
  57.                 Input( Student s){
  58.                 this.s = s;
  59.                 }
  60.         int x = 0;

  62.         @Override
  63.         public void run() {
  64.                 while (true) {
  65.                         synchronized (s) {
  66.                                 if (s.flag)
  67.                                         try {
  68.                                                 s.wait();
  69.                                         } catch (InterruptedException e1) {
  70.                                                 // TODO Auto-generated catch block
  71.                                                 e1.printStackTrace();
  72.                                         }
  73.                                 if (x == 0) {
  74.                                         s.setName("张三");
  75.                                         try {
  76.                                                 Thread.sleep(10);
  77.                                         } catch (InterruptedException e) {
  78.                                                 // TODO Auto-generated catch block
  79.                                                 e.printStackTrace();
  80.                                         }
  81.                                         s.setSex("男");
  82.                                 } else {

  84.                                         s.setName("lili");
  85.                                         try {
  86.                                                 Thread.sleep(10);
  87.                                         } catch (InterruptedException e) {
  88.                                                 // TODO Auto-generated catch block
  89.                                                 e.printStackTrace();
  90.                                         }
  91.                                         s.setSex("nvnvnnvnvnvnnv");
  92.                                 }
  93.                                                  x = (x + 1) % 2;
  94.                         s.flag = true;
  95.                         s.notify();
  96.                         }
  97.                        
  98.                 }
  99.         }
  100. }

  102. // 设计输出线程
  103. class Output implements Runnable {
  104.        private Student s;
  105.                 Output( Student s){
  106.                 this.s = s;
  107.                 }
  108.         @Override
  109.         public void run() {
  110.                 while (true){
  111.                         synchronized (s) {
  112.                                 if (!s.flag)
  113.                                         try {
  114.                                                 s.wait();
  115.                                         } catch (InterruptedException e) {
  116.                                                 // TODO Auto-generated catch block
  117.                                                 e.printStackTrace();
  118.                                         }
  119.                                 System.out.println(s.getName() + "-----" + s.getSex());
  120.                                 s.flag = false;
  121.                                 s.notify();
  122.                         }

  124.         }

  126. }
  127. }
复制代码
作者: 大神在何方    时间: 2015-3-13 23:39
看到那么多代码，以后我要是也会就好了。好怕自己学不会啊·感觉自己脑子不好使。会了成就感可大了
作者: Jaybor    时间: 2015-3-14 08:56
如果你有多个输入输出线程还应该把if(flag)修改成while(flag),把notify修改成notifyAll()



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