1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79
| import java.util.concurrent.ArrayBlockingQueue; import java.util.concurrent.BlockingQueue;
public class Demo09_BlockingQueue { private static BlockingQueue<String> queue = new ArrayBlockingQueue<>(5);
private static class Producer extends Thread { @Override public void run() { System.out.print("进入线程准备生产: " + Thread.currentThread() + "\n"); try { queue.put("product"); } catch (InterruptedException e) { e.printStackTrace(); } System.out.print(Thread.currentThread() + "生产结束...\n"); } }
private static class Consumer extends Thread { @Override public void run() { try { String product = queue.take(); } catch (InterruptedException e) { e.printStackTrace(); } System.out.print(Thread.currentThread() + " consume...\n\n"); } }
public static void main(String[] args) { for (int i = 0; i < 3; i++) { Producer producer = new Producer(); producer.start(); } for (int i = 0; i < 5; i++) { Consumer consumer = new Consumer(); consumer.start(); } for (int i = 0; i < 2; i++) { Producer producer = new Producer(); producer.start(); } } }
|