java实现生产者消费者问题(附完整源码)

下面是一个基于Java中的线程和锁机制实现的生产者消费者问题的代码，使用了阻塞队列来实现：

import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.BlockingQueue;

public class ProducerConsumer {
    public static void main(String[] args) {
        BlockingQueue<Integer> queue = new ArrayBlockingQueue<>(10);

        Thread producer = new Thread(new Producer(queue));
        Thread consumer = new Thread(new Consumer(queue));

        producer.start();
        consumer.start();
    }
}

class Producer implements Runnable {
    private final BlockingQueue<Integer> queue;

    public Producer(BlockingQueue<Integer> queue) {
        this.queue = queue;
    }

    @Override
    public void run() {
        for (int i = 0; i < 10; i++) {
            try {
                queue.put(i);
                System.out.println("Produced: " + i);
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
}

class Consumer implements Runnable {
    private final BlockingQueue<Integer> queue;

    public Consumer(BlockingQueue<Integer> queue) {
        this.queue = queue;
    }

    @Override
    public void run() {
        while (true) {
            try {
                Integer value = queue.take();
                System.out.println("Consumed: " + value);
                Thread.sleep(2000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
}

在此示例中，我们创建了一个BlockingQueue来存储生产者生成的整数。生产者线程使用put()方法将整数添加到队列中，而消费者线程则使用take()方法从队列中移除整数。阻塞队列会自动处理同步和线程安全问题。

在这个示例中，生产者线程将10个整数添加到队列中，消费者线程将无限循环地从队列中读取整数。在输出中，您将看到生产者和消费者线程交替执行，并且由于我们设置了不同的睡眠时间，消费者线程比生产者线程执行得更慢。