使用waitnotify实现生产者消费者

    xiaoxiao2021-12-14  16

    使用wait/notify实现生产者消费者代码:

    package com.cjy.concurrent; import java.util.LinkedList; class Producer extends Thread { LinkedList<String> list; public Producer(LinkedList<String> list) { this.list = list; } @Override public void run() { try { int num = 0; for (int i = 0; i <= 20; i++) { synchronized (list) { if (list.size() >= 5) { list.wait(); } if (list.add(String.valueOf(num))) { System.out.println("生产者生产产品:" + String.valueOf(num) + " [ 队列大小:" + list.size() + " ]"); num++; list.notifyAll(); Thread.sleep(500); } } } } catch (InterruptedException e) { e.printStackTrace(); } } } class Consumer extends Thread { LinkedList<String> list; public Consumer(LinkedList<String> list) { this.list = list; } @Override public void run() { try { for (int j = 0; j <= 20; j++) { synchronized (list) { if (list.size() <= 0) { list.wait(); } String s = list.remove(0); if(s!=null){ System.out.println("**消费者消费产品***: " + s + " [ 队列大小:" + list.size() + " ]"); Thread.sleep(500); list.notifyAll(); } } } } catch (InterruptedException e) { e.printStackTrace(); } } } public class ProducterCustomer { public static LinkedList<String> list = new LinkedList<String>(); public static void main(String[] args) { Producer producer = new Producer(list); Consumer consumer = new Consumer(list); ((Producer) producer).start(); ((Consumer) consumer).start(); } } 测试结果:

    生产者生产产品:0       [ 队列大小:1 ] 生产者生产产品:1       [ 队列大小:2 ] 生产者生产产品:2       [ 队列大小:3 ] 生产者生产产品:3       [ 队列大小:4 ] 生产者生产产品:4       [ 队列大小:5 ] **消费者消费产品***: 0       [ 队列大小:4 ] **消费者消费产品***: 1       [ 队列大小:3 ] **消费者消费产品***: 2       [ 队列大小:2 ] **消费者消费产品***: 3       [ 队列大小:1 ] **消费者消费产品***: 4       [ 队列大小:0 ] 生产者生产产品:5       [ 队列大小:1 ] 生产者生产产品:6       [ 队列大小:2 ] 生产者生产产品:7       [ 队列大小:3 ] 生产者生产产品:8       [ 队列大小:4 ] 生产者生产产品:9       [ 队列大小:5 ] **消费者消费产品***: 5       [ 队列大小:4 ] **消费者消费产品***: 6       [ 队列大小:3 ] **消费者消费产品***: 7       [ 队列大小:2 ] **消费者消费产品***: 8       [ 队列大小:1 ] **消费者消费产品***: 9       [ 队列大小:0 ] 生产者生产产品:10       [ 队列大小:1 ] 生产者生产产品:11       [ 队列大小:2 ] 生产者生产产品:12       [ 队列大小:3 ] 生产者生产产品:13       [ 队列大小:4 ] 生产者生产产品:14       [ 队列大小:5 ] **消费者消费产品***: 10       [ 队列大小:4 ] **消费者消费产品***: 11       [ 队列大小:3 ] **消费者消费产品***: 12       [ 队列大小:2 ] **消费者消费产品***: 13       [ 队列大小:1 ] **消费者消费产品***: 14       [ 队列大小:0 ] 生产者生产产品:15       [ 队列大小:1 ] 生产者生产产品:16       [ 队列大小:2 ] 生产者生产产品:17       [ 队列大小:3 ] 生产者生产产品:18       [ 队列大小:4 ] 生产者生产产品:19       [ 队列大小:5 ] **消费者消费产品***: 15       [ 队列大小:4 ] **消费者消费产品***: 16       [ 队列大小:3 ] **消费者消费产品***: 17       [ 队列大小:2 ] **消费者消费产品***: 18       [ 队列大小:1 ] **消费者消费产品***: 19       [ 队列大小:0 ] 生产者生产产品:20       [ 队列大小:1 ] **消费者消费产品***: 20       [ 队列大小:0 ]

    转载请注明原文地址: https://ju.6miu.com/read-965730.html

    最新回复(0)