ProducerConsumerDemo

1package com.my.demo;
2import java.util.Arrays;
3import java.util.LinkedList;
4import java.util.Random;
5import java.util.Scanner;
6
7public class ProducerConsumerDemo {
8	public static void main(String args[]) {
9		LinkedList<Integer> buffer = new LinkedList<>();
10		new Producer(buffer, "P1").start();
11		new Consumer(buffer, "C1").start();
12		new Consumer(buffer, "C2").start();
13		new Consumer(buffer, "C3").start();
14	}
15}
16
17class Producer extends Thread {
18	private LinkedList<Integer> list;
19
20	public Producer(LinkedList<Integer> list, String name) {
21		super(name);
22		this.list = list;
23	}
24
25	@Override
26	public void run() {
27		try {
28			Scanner scanner = new Scanner(System.in);
29			while (true) {
30				String line = scanner.nextLine();
31				if (line.startsWith("p")) {//produce. example: p8->produce 8 items
32					fillList(Integer.parseInt(line.substring(1)));
33				} else if (line.startsWith("b")) {//break producer.
34					break;
35				}
36			}
37			scanner.close();
38			System.out.println(getName() + " exit.");
39		} catch (Exception e) {
40			System.out.println(getName() + " Producer exception.");
41		}
42	}
43	
44	private void fillList(int count) {
45		synchronized (list) {
46			for (int n = 0; n < count; n++) {
47				//如果list已满，则等待
48				if (list.size() >= 20) {
49					try {
50						System.out.println(getName() + " List is full, Producer wait.");
51						list.wait();
52					} catch (Exception ex) {
53						ex.printStackTrace();
54					}
55				}
56				
57				//如果list没有满，则继续生产
58				Random random = new Random();
59				int i = random.nextInt(90) + 10;
60				list.add(i);
61				list.notifyAll();
62			}
63		}
64	}
65}
66
67class Consumer extends Thread {
68	private LinkedList<Integer> list;
69
70	public Consumer(LinkedList<Integer> list, String name) {
71		super(name);
72		this.list = list;
73	}
74
75	@Override
76	public void run() {
77		while (true) {
78			synchronized (list) {
79				if (list.isEmpty()) {
80					System.out.println(getName() + " List is empty, Consumer wait.");
81					try {
82						list.wait();
83					} catch (Exception ex) {
84						ex.printStackTrace();
85					}
86				}
87				System.out.println(getName() + " Consuming: " + list.removeLast() + ", list.size=" + list.size() + ", list=" + Arrays.toString(list.toArray()));
88				list.notifyAll();
89			}
90			try {
91				Thread.sleep(200);
92			} catch (InterruptedException e) {
93				System.out.println(getName() + " Consumer interrupted");
94			}
95		}
96	}
97}