Java多线程同步问题：简单生产者-消费者例子

原创ゝ一世哀愁。 2024-10-10 04:27 45阅读 0赞

在Java中，多线程的同步通常通过各种锁机制来实现。这里我们以简单的生产者-消费者模型为例，使用synchronized关键字进行同步。

1. 生产者类（Producer）：
```java
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;

public class Producer {
    private final Lock lock = new ReentrantLock();

public void produce() {
        lock.lock();
        try {
            // 生产操作，比如生产产品
            System.out.println("Producer produces an item.");
            // 消耗锁资源，等待其他线程释放锁
            lock.unlock();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}
```

2. 消费者类（Consumer）：
```java
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;

public class Consumer {
    private final Lock lock = new ReentrantLock();

public void consume() {
        lock.lock();
        try {
            // 消费操作，比如消费产品
            System.out.println("Consumer consumes an item.");
            // 验证生产者是否已经完成生产
            if (Producer.produceStatus()) {
                System.out.println("Product is produced. Consumer can now consume.");
            }
            // 释放锁资源，让其他线程有机会使用
            lock.unlock();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}
```

在生产者-消费者模型中，生产者负责生产产品，并将其放入队列或共享内存。消费者则通过循环等待队列中的产品，然后消费这些产品。

同步是确保多线程之间正确交互的关键。上述代码使用synchronized关键字来实现对生产锁和消费锁的控制。