黑马程序员技术交流社区

标题: 多线程-生产者消费者 [打印本页]
作者: kemeng    时间: 2015-3-16 15:51
标题: 多线程-生产者消费者
  1. class Demo1
  2. {
  3.         public static void main(String[] args)
  4.         {
  5.                 Resource r=new Resource();

  7.                 Producer pro=new Producer(r);
  8.                 Consumer con=new Consumer(r);

  10.                 Thread t1=new Thread(pro);
  11.                 Thread t2=new Thread(pro);
  12.                 Thread t3=new Thread(con);
  13.                 Thread t4=new Thread(con);
  14.                 t1.start();
  15.                 t2.start();
  16.                 t3.start();
  17.                 t4.start();
  18.         }
  19. }


  22. class Resource
  23. {
  24.         private String name;
  25.         private int count=1;
  26.         private boolean flag=false;

  28.         public synchronized void set(String name)
  29.         {
  30.                 while(flag)
  31.                         try
  32.                         {
  33.                                 wait();
  34.                         }
  35.                         catch (Exception e)
  36.                         {
  37.                         }
  38.                 this.name=name+"--"+count++;
  39.                 System.out.println(Thread.currentThread().getName()+"...生产者..."+this.name);
  40.                 flag=true;
  41.                 this.notifyAll();
  42.         }
  43.         public synchronized void out()
  44.         {
  45.                 while(!flag)
  46.                         try
  47.                         {
  48.                                 wait();
  49.                         }
  50.                         catch (Exception e)
  51.                         {
  52.                         }
  53.                 System.out.println(Thread.currentThread().getName()+"消费者"+this.name);
  54.                 flag=false;
  55.                 this.notifyAll();
  56.         }
  57. }

  59. class Producer implements Runnable
  60. {
  61.         private Resource res;
  62.         Producer(Resource res)
  63.         {
  64.                 this.res=res;
  65.         }
  66.         public void run()
  67.         {
  68.                 while(true)
  69.                 {
  70.                         res.set("+商品+");
  71.                 }
  72.         }
  73. }
  74. class Consumer implements Runnable
  75. {
  76.         private Resource res;
  77.         Consumer(Resource res)
  78.         {
  79.                 this.res=res;
  80.         }
  81.         public void run()
  82.         {
  83.                 while(true)
  84.                 {
  85.                         res.out();
  86.                 }
  87.         }
  88. }
复制代码






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