Java线程生产者消费者简单应用

avatar 2017年05月29日10:45:37 0 2359 views
博主分享免费Java教学视频，B站账号：Java刘哥 ，长期提供技术问题解决、项目定制：本站商品点此
题目
借助线程同步机制对四个线程进行输出

1线程输出：甲、乙、丙、丁、戊

2线程输出：aa、bb、cc、dd、ee

3线程数出：A、B、C、D、E

4线程输出：1、2、3、4、5

最终输出效果应该为：甲 aa A 1 乙 bb B 2 丙 cc C 3 丁 dd D 4 戊 ee E 5

分析

很显然，需要用到线程“生产者消费者”案例，即wait()和notify()的使用。

这里可以参考

Java线程生产者和消费者实例


代码如下
  1. package com.liuyanzhao;
  3. /*
  4.  *
  5.  * @author WellsLiu
  6.  *
  7.  */
  9. class Rescouce {
  10.     boolean flag = true;
  11. }
  13. class Thread1 extends Thread{
  14.     Rescouce res;
  15.     public Thread1(Rescouce res) {
  16.         this.res = res;
  17.     }
  18.     String []c1 = {"甲","乙","丙","丁","戊"};
  19.     String []c2 = {"aa","bb","cc","dd","ee"};
  20.     public  void run() {
  21.         synchronized (res) {
  22.             for(int i=0;i<5;i++) {
  23.                 while(!res.flag){
  24.                     try {
  25.                         res.wait();
  26.                     } catch (InterruptedException e) {
  27.                         e.printStackTrace();
  28.                     }
  29.                 }
  30.                 System.out.print(c1[i]+" ");
  31.                 System.out.print(c2[i]+" ");
  32.                 res.flag=false;
  33.                 res.notifyAll();
  34.             }
  36.         }
  37.     }
  38. }
  40. class Thread2 extends Thread{
  41.     Rescouce res;
  42.     public Thread2(Rescouce res) {
  43.         this.res = res;
  44.     }
  45.     String []c1 = {"A","B","C","D","E"};
  46.     String []c2 = {"1","2","3","4","5"};
  47.     public synchronized void run() {
  48.         synchronized (res) {
  49.             for(int i=0;i<5;i++) {
  50.                 while(res.flag){
  51.                     try {
  52.                         res.wait();
  53.                     } catch (InterruptedException e) {
  54.                         e.printStackTrace();
  55.                     }
  56.                 }
  57.                 System.out.print(c1[i]+" ");
  58.                 System.out.print(c2[i]+" ");
  59.                 res.flag=true;
  60.                 res.notifyAll();
  61.             }
  63.         }
  64.     }
  65. }
  67. public class Test {
  68.     public static void main(String[] args) {
  69.         Rescouce res = new Rescouce();
  70.         new Thread1(res).start();
  71.         new Thread2(res).start();
  72.     }
  73. }

运行结果



本文链接：
历史上的今天
五月
29日
  • 微信
  • 交流学习，资料分享
  • weinxin
  • 个人淘宝
  • 店铺名：言曌博客咨询部

  • (部分商品未及时上架淘宝)
avatar

发表评论

avatar 登录者：匿名
匿名评论，评论回复后会有邮件通知

  

已通过评论：0   待审核评论数：0