揭秘Java并发编程模式：探索生产者-消费者、读写锁等经典模式

package com.example.javase.ms.threadDemo;

import java.util.ArrayList;
import java.util.List;

/**
 * @Author ms
 * @Date 2023-12-16 18:05
 */
// 具体的测试用例代码示例
public class ProducerConsumerExample {
    public static void main(String[] args) {
        Buffer buffer = new Buffer();
        Thread producerThread = new ProducerThread(buffer);
        Thread consumerThread = new ConsumerThread(buffer);
        producerThread.start();
        consumerThread.start();
    }

    static class Buffer {
        private List<Integer> data = new ArrayList<>();
        private int maxSize = 5;

        public synchronized void produce(int value) throws InterruptedException {
            while (data.size() >= maxSize) {
                wait();
            }
            data.add(value);
            System.out.println("Produced: " + value);
            notifyAll();
        }

        public synchronized int consume() throws InterruptedException {
            while (data.size() == 0) {
                wait();
            }
            int value = data.get(0);
            data.remove(0);
            System.out.println("Consumed: " + value);
            notifyAll();
            return value;
        }
    }

    static class ProducerThread extends Thread {
        private Buffer buffer;

        public ProducerThread(Buffer buffer) {
            this.buffer = buffer;
        }

        @Override
        public void run() {
            try {
                for (int i = 1; i <= 10; i++) {
                    buffer.produce(i);
                    Thread.sleep(1000);
                }
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }

    static class ConsumerThread extends Thread {
        private Buffer buffer;

        public ConsumerThread(Buffer buffer) {
            this.buffer = buffer;
        }

        @Override
        public void run() {
            try {
                for (int i = 1; i <= 10; i++) {
                    int value = buffer.consume();
                    Thread.sleep(2000);
                }
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
}