黑马程序员技术交流社区

标题: 多线程 生产者 消费者 [打印本页]
作者: fmi110    时间: 2015-10-6 16:06
标题: 多线程 生产者 消费者
  1. package demo;

  3. public class ProducerAndConsuDemo {

  5.         /**
  6.          * 模拟生产者和消费者
  7.          */
  8.         public static void main(String[] args) {
  9.                 Resource r = new Resource();
  10.                 for(int i = 1;i<4;i++){
  11.                         new Thread(new Pro(r)).start();
  12.                         new Thread(new Consu(r)).start();
  13.                 }

  15.         }

  17. }
  18. class Resource{
  19.         private String name;
  20.         private int count = 0;
  21.         private boolean flag = false;
  22.        
  23.         public void produce(){
  24.                 synchronized(this){
  25.                         while(flag){
  26.                                 try {
  27.                                         Thread.sleep(10);
  28.                                         this.wait();
  29.                                 } catch (InterruptedException e) {
  30.                                         e.printStackTrace();
  31.                                 }
  32.                         }
  33.                         count++;
  34.                         System.out.println(Thread.currentThread().getName()+"...生产"+count);
  35.                         flag = flag^true;
  36.                         this.notifyAll();
  37.                 }
  38.         }
  39.         public void sell(){
  40.                 synchronized(this){
  41.                         while(!flag){
  42.                                 try {
  43.                                         Thread.sleep(50);
  44.                                         this.wait();
  45.                                 } catch (InterruptedException e) {
  46.                                         e.printStackTrace();
  47.                                 }
  48.                         }
  49.                         System.out.println(Thread.currentThread().getName()+"...消费"+count);
  50.                         flag = flag^true;
  51.                         this.notifyAll();
  52.                 }
  53.         }
  54. }
  55. class Pro implements Runnable{
  56.         private Resource r;

  58.         public Pro(Resource r) {
  59.                 super();
  60.                 this.r = r;
  61.         }

  63.         @Override
  64.         public void run() {
  65.                 while(true){
  66.                         r.produce();
  67.                 }
  68.         }
  69. }
  70. class Consu implements Runnable{
  71.         private Resource r;

  73.         public Consu(Resource r) {
  74.                 super();
  75.                 this.r = r;
  76.         }

  78.         @Override
  79.         public void run() {
  80.                 while(true){
  81.                         r.sell();
  82.                 }
  83.         }
  84. }
复制代码
作者: fmi110    时间: 2015-10-6 16:11
  1. Thread-0...生产1
  2. Thread-5...消费1
  3. Thread-4...生产2
  4. Thread-3...消费2
  5. Thread-2...生产3
  6. Thread-1...消费3
  7. Thread-2...生产4
  8. Thread-3...消费4
  9. Thread-4...生产5
  10. Thread-5...消费5
复制代码




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