黑马程序员技术交流社区

标题: 基础学习day12多线程2消费者生产者 [打印本页]
作者: 不怕黑人    时间: 2015-7-22 22:17
标题: 基础学习day12多线程2消费者生产者
  1. public class Day12Test1 {

  3.         public static void main(String[] args) {

  5.                 Resouce r = new Resouce();
  6.                 new Thread(new Producer(r)).start();
  7.                 new Thread(new Producer(r)).start();
  8.                 new Thread(new Consumer(r)).start();
  9.                 new Thread(new Consumer(r)).start();
  10.         }

  12. }

  14. class Resouce{
  15.        
  16.         private String name;
  17.         private int count = 1;
  18.         private boolean flag = false;
  19.         public synchronized void set(String name){
  20.                
  21.                 while(flag)
  22.                         try{
  23.                                 wait();
  24.                         }
  25.                         catch(Exception e){
  26. //                                throw new RuntimeException();
  27.                         }
  28.                         this.name = name + count++;
  29.                         System.out.println(Thread.currentThread().getName()+"...生产者......"+this.name);
  30.                         flag = true;
  31.                         notifyAll();
  32.         }
  33.         public synchronized void out(){
  34.                 while(!flag)
  35.                         try{
  36.                                 wait();
  37.                         }
  38.                         catch(Exception e){
  39. //                                throw new RuntimeException();
  40.                         }
  41.                         System.out.println(Thread.currentThread().getName()+"+消费者+"+this.name);
  42.                         flag = false;
  43.                         notifyAll();
  44.         }
  45. }
  46. class Producer implements Runnable{
  47.         private Resouce r;
  48.         Producer(Resouce r){
  49.                 this.r = r;
  50.         }
  51.         public void run(){
  52.                 while(true){
  53.                         r.set("汉堡");
  54.                 }
  55.         }
  56. }
  57. class Consumer implements Runnable{
  58.         private Resouce r;
  59.         Consumer(Resouce r){
  60.                 this.r = r;
  61.         }
  62.         public void run(){
  63.                 while(true){
  64.                         r.out();
  65.                 }
  66.         }
  67. }
复制代码




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