A股上市公司传智教育（股票代码 003032）旗下技术交流社区北京昌平校区

传智教育官网黑马程序员官网

 找回密码
 加入黑马

QQ登录

只需一步，快速开始

论坛首页 › 学习交流 › 技术交流 › Java技术交流 › 正文

[学习交流] 多线程 代码示例 来自毕老师视频教程

© fmi110 高级黑马   /  2015-7-19 11:57  /  318 人查看  /  0 人回复  /   0 人收藏 转载请遵从CC协议 禁止商业使用本文

多线程
  1. /*需求：建立两个线程，一个进行输入人的信息，一个负责输出，两个线程交替运行
  2.                 人的信息：name，sex
  3.   分析：1 输入输出的对象均是人
  4.                         故人单独分类，成员变量 ：name、sex；
  5.                         同时提供访问和输出成员变量的方法：setInfo out
  6.                         因为setInfo 和 out 两个方法可能被调用同时访问成员变量，因此需要进行同步，
  7.                         只有一个方法访问问成员变量后，才能允许另一个访问。
  8.                 2 输入及输出线程，可通过继承Runnable类，然后覆盖run方法实现
  9.                 3 为确保输入输出线程处理的是同一对象，在创建线程时，应该将对象传递给线程
  10. */
  11. /*版本一 待优化
  12. class Res
  13. {
  14.         private String name;
  15.         private String sex;
  16.         boolean flag = false; //用于标识输出或者输入

  18.         public void setInfo(String name,String sex)
  19.         {
  20.                 this.name = name;
  21.                 this.sex = sex;
  22.         }
  23.         public void out()
  24.         {
  25.                 System.out.println(this.name + "..." + this.sex);
  26.         }
  27. }
  28. class Input implements Runnable
  29. {
  30.         private Res r;        //用于接收操作的对象
  31.         Input(Res r)
  32.         {
  33.                 this.r = r;
  34.         }
  35.         public void run()        //复写run方法，自定义线程的功能：输入信息，交替输入两个人的信息
  36.         {
  37.                 int x = 0;

  39.                 while(true)
  40.                 {
  41.                         synchronized(r)
  42.                         {
  43.                                 if(r.flag)
  44.                                         try{r.wait();}catch (InterruptedException e){}

  46.                                 if(x==0)
  47.                                         r.setInfo("lisi","man");
  48.                                 else
  49.                                         r.setInfo("莉莉","女女");
  50.                                 x = (x+1)%2;

  52.                                 r.flag = (true);        //设置输入完成
  53.                                 r.notify();        //唤醒输出
  54.                         }
  55.                 }
  56.         }
  57. }

  59. class Output implements Runnable
  60. {
  61.         private Res r;        //用于接收操作的对象

  63.         Output(Res r)
  64.         {
  65.                 this.r = r;
  66.         }
  67.         public void run()        //复写run方法，自定义线程的功能：输入信息，交替输入两个人的信息
  68.         {
  69.                 while(true)
  70.                 {
  71.                         synchronized(r)
  72.                         {
  73.                                 if(!r.flag)
  74.                                         try{r.wait();}catch (InterruptedException e){}
  75.                                 r.out();
  76.                                 r.flag = (false);        //设置输出完成标志
  77.                                 r.notify();        //唤醒输入
  78.                         }
  79.                 }
  80.         }
  81. }

  83. */
  84. /*版本二  优化后*/
  85. class Res
  86. {
  87.         private String name;
  88.         private String sex;
  89.         private boolean flag = false; //用于标识输出或者输入

  91.         public synchronized void setInfo(String name,String sex)
  92.         {
  93.                 if(flag)
  94.                         try{this.wait();}catch (InterruptedException e){}  //wait()会抛出异常（函数内，声明后抛或者catch），需要进行处理
  95.                 this.name = name;
  96.                 this.sex = sex;
  97.                 flag = true;        //设置输入完成标识
  98.                 this.notify();        //唤醒输出
  99.         }
  100.         public synchronized void out()
  101.         {
  102.                 if(!flag)
  103.                         try{wait();}catch (InterruptedException e){}
  104.                 System.out.println(this.name + "..." + this.sex);
  105.                 flag = false;        //设置输出完成标识
  106.                 this.notify();        //唤醒输入
  107.         }
  108. }

  110. class Input implements Runnable
  111. {
  112.         private Res r;        //用于接收操作的对象
  113.         Input(Res r)
  114.         {
  115.                 this.r = r;
  116.         }
  117.         public void run()        //复写run方法，自定义线程的功能：输入信息，交替输入两个人的信息
  118.         {
  119.                 int x = 0;
  120.                 while(true)
  121.                 {
  122.                         if(x==0)
  123.                                 r.setInfo("lisi","man");
  124.                         else
  125.                                 r.setInfo("莉莉","女女");
  126.                         x = (x+1)%2;
  127.                 }
  128.         }
  129. }
  130. class Output implements Runnable
  131. {
  132.         private Res r;        //用于接收操作的对象
  133.         Output(Res r)
  134.         {
  135.                 this.r = r;
  136.         }
  137.         public void run()        //复写run方法，自定义线程的功能：输入信息，交替输入两个人的信息
  138.         {
  139.                 while(true)
  140.                 {
  141.                         r.out();
  142.                 }
  143.         }
  144. }
  145. class  InputOutputDemo
  146. {
  147.         public static void main(String[] args)
  148.         {
  149.                 Res r = new Res();
  150.                 new Thread(new Input(r)).start();
  151.                 new Thread(new Output(r)).start();
  152.         }
  153. }



复制代码


视频教程多线程

0 个回复

高级模式
B Color Image Link Quote Code Smilies
您需要登录后才可以回帖 登录 | 加入黑马