黑马程序员技术交流社区

标题: 多线程问题。 [打印本页]
作者: 于启会    时间: 2012-9-5 15:13
标题: 多线程问题。
本帖最后由 于启会 于 2012-9-5 16:56 编辑
  1. <p>----Resource类：
  2. package com.Demo;</p><p>public class Resource {
  3. private String name;
  4. private String sex;
  5. private boolean flog=false;
  6. public void set(String name,String sex){
  7.   synchronized (this) {
  8.    if(flog){
  9.     try{
  10.      this.wait();
  11.      }catch (Exception e) {
  12.      }
  13.    }
  14.    this.name=name;
  15.    this.sex=sex;
  16.    flog=true;
  17.    this.notify();
  18.   }
  19. }

  21. public void get(){
  22.   synchronized (this) {
  23.    if(!flog){
  24.     try{
  25.      this.wait();
  26.     }catch (Exception e) {
  27.     }
  28.    }
  29.    System.out.println(name+"......"+sex);
  30.    flog=false;
  31.    this.notify();
  32.   }
  33. }
  34. }

  36. -----Input类：
  37. package com.Demo;</p><p>public class Input implements Runnable{
  38. private Resource r;
  39. public Input(Resource r){
  40.   this.r=r;
  41. }
  42. public void run() {
  43.   int x=0;
  44.   while(true){
  45.    if(x==0){
  46.     r.set("丽丽", "女");
  47.    }else{
  48.     r.set("龙龙", "男");
  49.    }
  50.    x=(x+1)%2;
  51.   }
  52. }
  53. }
  54. ----Output类:
  55. package com.Demo;</p><p>public class Output implements Runnable{
  56. private Resource r;
  57. public Output(Resource r){
  58.   this.r=r;
  59. }
  60. public void run() {
  61.   while(true){
  62.    r.get();
  63.   }
  64. }</p><p>}

  66. ---MainDemo类:
  67. package com.Demo;</p><p>public class MainDemo {
  68. public static void main(String[] args) {
  69.   new Thread(new Input(new Resource())).start();
  70.   new Thread(new Output(new Resource())).start();
  71. }
  72. }

  74. 打印结果是null....null闪一下然后不输出，求指导。。</p>
复制代码
作者: 杨卫腾    时间: 2012-9-5 16:32
  1. class Resouce
  2. {
  3.         private String name;
  4.         private String sex;
  5.         private boolean flag = true;
  6.         Resouce()
  7.         {
  8.         }
  9.         Resouce(String name,String sex)
  10.         {
  11.                 this.name = name;
  12.                 this.sex = sex;
  13.         }
  14.        
  15.         public synchronized void setRes(String name,String sex)
  16.         {
  17.                 if(!flag)
  18.                         try
  19.                         {
  20.                                 wait();
  21.                         }
  22.                         catch (InterruptedException ie)
  23.                         {
  24.                                 ie.printStackTrace();
  25.                         }
  26.                 this.name = name;
  27.                 this.sex = sex;

  29.                 flag = false;
  30.                 notify();
  31.         }
  32.        
  33.         public synchronized void getRes()
  34.         {
  35.                 if(flag)
  36.                         try
  37.                         {
  38.                                 wait();
  39.                         }
  40.                         catch (InterruptedException ie)
  41.                         {
  42.                                 ie.printStackTrace();
  43.                         }
  44.                 System.out.println(/*Thread.currentThread().getName()+*/"name:"+name+"..."+"sex:"+sex);
  45.                 flag = true;
  46.                 notify();
  47.         }
  48. }

  50. class  Input implements Runnable
  51. {
  52.         private  Resouce r;

  54.         Input(Resouce r)
  55.         {
  56.                 this.r = r;
  57.         }
  58.         public void run()
  59.         {
  60.                 int x = 0;
  61.                 while(true)
  62.                 {
  63.                         if(x==0)
  64.                                 r.setRes("丽丽","女");
  65.                         else
  66.                                 r.setRes("龙龙","男");
  67.                         x = (x+1)%2;
  68.                 }
  69.         }
  70. }
  71. class Output implements Runnable
  72. {
  73.         private Resouce r;
  74.         Output(Resouce r)
  75.         {
  76.                 this.r = r;
  77.         }
  78.         public void run()
  79.         {
  80.                 while(true)
  81.                 {
  82.                         r.getRes();
  83.                 }
  84.         }
  85. }

  87. class  InputOutputThread2
  88. {
  89.         public static void main(String[] args)
  90.         {
  91.                 Resouce r = new Resouce();
  92.                
  93.                 new Thread(new Input(r),"存储").start();
  94.                 new Thread(new Output(r),"读出").start();
  95.         }
  96. }
复制代码
看看这个结果行不行
作者: 袁艳超    时间: 2012-9-5 16:37
你定义了两个Resource类的对象，可以这样分析一下，
先分别给两个Resource类的对象命名一下，一个是Resource A ,一个是Resource B;
简称一下线程,一个是线程input,一个是线程output
input线程先启动,给A 设置进去了name和age的值,然后就wait等着output线程来取,
可是,output线程已启动却是等着取出B的值,
它们将一直等下去,因为不会有线程给B设置,也不会有线程去取A的值
所以,把main方法里的代码修改如下:
Resource res = new Resource();  //创建一个Resource对象让两个线程去操作,否则你定义的synchronized同步方法没有意义嘛!
new Thread(new Input(res)).start();
new Thread(new Output(res)).start();
另外,唤醒线程的方法,尽量不要用notify;要用notifyAll,因为线程都是线程调度器来调用的,你是控制不了的,所以用notify有时会出问题
作者: 于启会    时间: 2012-9-5 16:55
袁艳超 发表于 2012-9-5 16:37
你定义了两个Resource类的对象，可以这样分析一下，
先分别给两个Resource类的对象命名一下，一个是Resourc ...

额   创建对象那里写错了。。找了半天就是没找main方法中的代码。。受教了。。:hug:



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