java多线程怎么实现生产者消费者模式

在Java中，可以使用wait()和notify()或notifyAll()方法来实现生产者-消费者模式。这些方法是Object类的一部分，用于线程间的通信。下面是一个简单的生产者-消费者模式示例：

1. 首先，创建一个共享资源类，例如一个缓冲区（Buffer）：

public class Buffer {
    private int data;
    private boolean empty = true;

    public synchronized void put(int data) {
        while (!empty) {
            try {
                wait();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        this.data = data;
        empty = false;
        notifyAll();
    }

    public synchronized int get() {
        while (empty) {
            try {
                wait();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        empty = true;
        notifyAll();
        return data;
    }
}

2. 创建生产者线程类：

public class Producer implements Runnable {
    private Buffer buffer;

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

    @Override
    public void run() {
        for (int i = 0; i < 10; i++) {
            System.out.println("Produced: " + i);
            buffer.put(i);
        }
    }
}

3. 创建消费者线程类：

public class Consumer implements Runnable {
    private Buffer buffer;

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

    @Override
    public void run() {
        for (int i = 0; i < 10; i++) {
            int data = buffer.get();
            System.out.println("Consumed: " + data);
        }
    }
}

4. 在主程序中创建生产者和消费者线程，并启动它们：

public class Main {
    public static void main(String[] args) {
        Buffer buffer = new Buffer();
        Thread producerThread = new Thread(new Producer(buffer));
        Thread consumerThread = new Thread(new Consumer(buffer));

        producerThread.start();
        consumerThread.start();
    }
}

运行上述代码，你将看到生产者和消费者线程交替执行，生产者将数据放入缓冲区，消费者从缓冲区中取出数据。这就是一个简单的生产者-消费者模式实现。