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;
    
13. 
    
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. }
    
27. 
    
28. class Consumer extends Thread {
    
29.     Warehouse w;
    
30. 
    
31.     Consumer(Warehouse w) {
    
32.         this.w = w;
    
33.     }
    
34. 
    
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.         }
    
59. 
    
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，谢谢大神帮忙。

按照我的印象，毕老师写的代码是有两个生产者和两个消费者的，所以这样就存在安全问题了啊。另外，消费者和生产者要有一个先后过程的啊，加同一个锁就是为了让生产者生产完了，消费者再去消费。

加锁不是为了解决程序的调用方法问题 ，put只有生存者调用 get只有消费者调用，这是没有问题的。加锁是为了解决线程的循序问题，cup选择线程是随机的，这样就会造成实际问题的混乱。。例如当cup在判断put方法还未结束时，切换到了 get方法 这样就有问题了 生产者还未生成结束 消费者就消费了。 加锁就是为了保证循序问题，

为了解决安全问题，避免出现生产线程还没有生产完，就已经消费了这样的情况，加同步的目的是让生产线程执行完以后才可以才执行消费消费线程