黑马程序员技术交流社区

标题: 生产消费线程问题，为什么要加synchronized [打印本页]
作者: tonygone    时间: 2013-7-18 12:57
标题: 生产消费线程问题，为什么要加synchronized
本帖最后由 杨兴庭 于 2013-7-18 21:26 编辑
  1. package com.zhangyg.thread.mytest;
  2. public class ThreadCommunication {
  3.     public static void main(String[] args) {
  4.         Warehouse w = new Warehouse();
  5.         Proudcer p = new Proudcer(w);
  6.         Consumer c = new Consumer(w);
  7.         p.start();
  8.         c.start();
  9.     }
  10. }
  11. class Proudcer extends Thread {
  12.     Warehouse w;

  14.     Proudcer(Warehouse w) {
  15.         this.w = w;
  16.     }
  17.     @Override
  18.     public void run() {
  19.         for (int i = 1; i <= 10; i++) {
  20.             // 生产商品
  21.             w.put(i);
  22.             //该语句引起问题
  23.             System.out.println("Producer 生产 " + i);
  24.         }
  25.     }
  26. }

  28. class Consumer extends Thread {
  29.     Warehouse w;

  31.     Consumer(Warehouse w) {
  32.         this.w = w;
  33.     }

  35.     @Override
  36.     public void run() {
  37.         while (true) {
  38.             //该语句引起问题
  39.             System.out.println("Customer "+" 消费 "+ w.get());
  40.         }
  41.     }
  42. }
  43. class Warehouse {
  44.     private int value;
  45.     boolean bFull = false; //仓库是否有商品
  46.     // 生产商品
  47.     public  void put(int value) {
  48.         if (!this.bFull) { // 仓库中没有商品
  49.             this.value = value;
  50.             this.bFull = true;
  51.             this.notify(); // 通知消费者进行消费
  52.         }
  53.         try {
  54.             this.wait(); // 等待消费者消费商品
  55.         } catch (InterruptedException e) {
  56.             // TODO Auto-generated catch block
  57.             e.printStackTrace();
  58.         }

  60.     }
  61.     // 消费商品
  62.     public  int get() {
  63.         if (!this.bFull) { //仓库中没有商品
  64.             try {
  65.                 this.wait(); //等待生产者生产商品
  66.             } catch (InterruptedException e) {
  67.                 // TODO Auto-generated catch block
  68.                 e.printStackTrace();
  69.             }
  70.         }
  71.         this.bFull = false;
  72.         this.notify(); //通知生产者生产商品
  73.         return this.value;
  74.    
复制代码
请问上面的put和get方法为什么要枷锁，synchronized加在一个方法上，代表这个方法只能一个选择去运行吗，我感觉这边put只有生存者去调用，而get也只有消费者去调用，没有别的方法竞争啊，为什么要加synchronized，谢谢大神帮忙。
作者: ＂O_忆_O    时间: 2013-7-18 13:04
按照我的印象，毕老师写的代码是有两个生产者和两个消费者的，所以这样就存在安全问题了啊。另外，消费者和生产者要有一个先后过程的啊，加同一个锁就是为了让生产者生产完了，消费者再去消费。
作者: yangqing    时间: 2013-7-18 13:19
加锁不是为了解决程序的调用方法问题 ，put只有生存者调用 get只有消费者调用，这是没有问题的。加锁是为了解决线程的循序问题，cup选择线程是随机的，这样就会造成实际问题的混乱。。例如当cup在判断put方法还未结束时，切换到了 get方法 这样就有问题了 生产者还未生成结束 消费者就消费了。 加锁就是为了保证循序问题，
作者: 付龙    时间: 2013-7-18 20:47
为了解决安全问题，避免出现生产线程还没有生产完，就已经消费了这样的情况，加同步的目的是让生产线程执行完以后才可以才执行消费消费线程



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