Java多线程中的生产者消费者问题实例

原创你的名字 2024-11-21 16:57 14阅读 0赞

在Java多线程中，生产者消费者问题是一个经典的并发模型。它模拟了两种角色：生产者（Producer）负责创建和提供产品，而消费者（Consumer）则负责消费这些产品。

以下是一个简单的Java实现例子：

```java
import java.util.LinkedList;
import java.util.Queue;

class Producer implements Runnable {
    private Queue<String> queue;
    public Producer(Queue<String> queue) {
        this.queue = queue;
    }
    @Override
    public void run() {
        for (int i = 0; i < 10; i++) {
            //生产产品
            String product = "Product-" + i;
            queue.add(product);
            System.out.println("Producer produced: " + product);
            try {
                //模拟线程等待
                Thread.sleep(500); //休眠500毫秒，模拟生产耗时
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
}

class Consumer implements Runnable {
    private Queue<String> queue;
    public Consumer(Queue<String> queue) {
        this.queue = queue;
    }
    @Override
    public void run() {
        while (!queue.isEmpty()) {
            //消费产品
            String product = queue.poll();
            System.out.println("Consumer consumed: " + product);
            try {
                //模拟线程等待
                Thread.sleep(1000); //休眠1秒，模拟处理耗时
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
}

public class Main {
    public static void main(String[] args) {
        Queue<String> productQueue = new LinkedList<>();
        
        //创建生产者和消费者线程
        Thread producerThread = new Thread(new Producer(productQueue)));
        Thread consumerThread = new Thread(new Consumer(productQueue)));

//启动生产者和消费者线程
        producerThread.start();
        consumerThread.start();

//等待所有线程执行完毕
        try {
            producerThread.join();
            consumerThread.join();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}
```

这段代码定义了生产者（Producer）和消费者（Consumer）两个角色，并通过多线程的方式模拟了生产者向消费者提供产品，然后消费者消费掉的过程。