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

 找回密码
 加入黑马

QQ登录

只需一步,快速开始

  1. public class ProducerConsumerTest {

  2.         public static void main(String[] args) {
  3.                 Resource res = new Resource();
  4.                 Producer p = new Producer(res);
  5.                 Consumer c = new Consumer(res);
  6.                
  7.                 Thread t1 = new Thread(p);
  8.                 Thread t2 = new Thread(c);
  9.                 Thread t3 = new Thread(p);
  10.                 Thread t4 = new Thread(c);
  11.                 t1.start();
  12.                 t2.start();
  13.                 t3.start();
  14.                 t4.start();

  15.         }

  16. }

  17. class Resource{
  18.         private String name;
  19.         private int count = 1;
  20.         private boolean flag = false;
  21.         public synchronized void set(String name){
  22.                 while(flag){
  23.                                 try{this.wait();}catch(Exception e){}
  24.                         this.name = name+"..."+count++;
  25.                         System.out.println(Thread.currentThread().getName()+"---生产者---"+this.name);
  26.                         flag = true;
  27.                         this.notifyAll();
  28.                 }
  29.         }
  30.         public synchronized void out(){
  31.                 while(!flag){
  32.                                 try{this.wait();}catch(Exception e){}
  33.                         System.out.println(Thread.currentThread().getName()+"-----消费者-----"+this.name);
  34.                         flag = false;
  35.                         this.notifyAll();
  36.                 }
  37.         }
  38. }
  39. class Producer implements Runnable{
  40.         private Resource res;
  41.         Producer(Resource res){
  42.                 this.res = res;
  43.         }
  44.         public void run() {
  45.                 while(true){
  46.                         res.set("zhangsan");
  47.                 }
  48.         }
  49.        
  50. }
  51. class Consumer implements Runnable{

  52.         private Resource res;
  53.         Consumer(Resource res){
  54.                 this.res = res;
  55.         }
  56.         public void run() {
  57.                 while(true){
  58.                         res.out();
  59.                 }
  60.         }
  61.        
  62. }
复制代码

看毕姥爷多线程视频写的生产者消费者,运行没反应,麻烦大家来瞅瞅

1 个回复

正序浏览
沙发 我还没看到哪里了
回复 使用道具 举报
您需要登录后才可以回帖 登录 | 加入黑马