1 package one.threadLearn.productAndCustomer.one;
 2
 3 public class Hosee {
 4     private static Integer count = 0;
 5     private final Integer  FULL  = 10;
 6     private static String  LOCK  = "LOCK";
 7
 8     class Producer implements Runnable {
 9         @Override
10         public void run() {
11             for (int i = 0; i < 10; i++) {
12                 try {
13                     Thread.sleep(3000);
14                 } catch (Exception e) {
15                     e.printStackTrace();
16                 }
17                 synchronized (LOCK) {
18                     while (count == FULL) {
19                         try {
20                             System.out.println("仓库满了");
21                             LOCK.wait();
22                         } catch (Exception e) {
23                             e.printStackTrace();
24                         }
25                     }
26                     count++;
27                     System.out.println(Thread.currentThread().getName() + "生产者生产，目前总共有" + count);
28                     LOCK.notifyAll();
29                 }
30             }
31         }
32     }
33
34     class Consumer implements Runnable {
35         @Override
36         public void run() {
37             for (int i = 0; i < 10; i++) {
38                 try {
39                     Thread.sleep(3000);
40                 } catch (InterruptedException e1) {
41                     e1.printStackTrace();
42                 }
43                 synchronized (LOCK) {
44                     while (count == 0) {
45                         try {
46                             System.out.println("库存空了");
47                             LOCK.wait();
48                         } catch (Exception e) {
49                         }
50                     }
51                     count--;
52                     System.out.println(Thread.currentThread().getName() + "消费者消费，目前总共有" + count);
53                     LOCK.notifyAll();
54                 }
55             }
56         }
57     }
58
59     public static void main(String[] args) throws Exception {
60         Hosee hosee = new Hosee();
61         new Thread(hosee.new Producer()).start();
62         new Thread(hosee.new Producer()).start();
63         new Thread(hosee.new Consumer()).start();
64         new Thread(hosee.new Producer()).start();
65         new Thread(hosee.new Consumer()).start();
66         new Thread(hosee.new Producer()).start();
67         new Thread(hosee.new Consumer()).start();
68         new Thread(hosee.new Producer()).start();
69         new Thread(hosee.new Consumer()).start();
70     }
71 }