Java线程并发问题：生产者-消费者模型实例

原创朱雀 2024-09-22 21:06 69阅读 0赞

在Java中，我们可以使用`java.util.concurrent`包中的组件来实现生产者-消费者模型。下面是一个简单的实例：

1. 创建线程类（Producer和Consumer）：

```java
public class ThreadExample {
    private final Object lock = new Object();

// 生产者线程
    public void producerThread() {
        while (true) {
            synchronized (lock) {
                // 生产一个产品
                System.out.println("Product generated by Producer");
                
                // 唤醒等待的消费者线程
                lock.notify();
            }
        }
    }

// 消费者线程
    public void consumerThread() {
        while (true) {
            synchronized (lock) {
                // 如果锁被生产者持有，则等待
                if (lock.isHeldByCurrentThread()) {
                    System.out.println("Consumer is waiting for a product.");
                    lock.wait();
                } else { // 产品可用
                    System.out.println("Consuming a product generated by Producer");
                    
                    // 唤醒生产者，告知其产品已被消费
                    lock.notifyAll();
                }
            }
        }
    }

public static void main(String[] args) {
        ThreadExample example = new ThreadExample();
        
        // 创建生产者线程并启动
        new Thread(example::producerThread).start();

// 创建消费者线程并启动
        new Thread(example::consumerThread)).start();
    }
}
```

这个例子中，我们有`Producer`和`Consumer`两个线程类。`Producer`负责生成产品并将其传递给`Consumer`。`Consumer`则会消费由`Producer`提供的产品。

在`main`方法中，我们创建了这两个线程并启动它们。这样就实现了生产者-消费者模型。