初学者：Java多线程并发问题实例

原创朱雀 2024-11-15 13:00 4阅读 0赞

作为初学者，理解Java多线程并发问题是编程进阶的重要环节。这里我将通过一个简单但实用的实例来逐步解释。

**实例：生产者-消费者模型**

1. **创建两个类：Producer和Consumer**

```java
// Producer.java
class Producer {
    private Object item;
    private final Object lock = new Object();

// 生产方法，这里只是一个模拟
    public synchronized void produce() {
        if (item == null) {
            try {
                // 生成时间间隔
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            item = "Product A"; // 假设生产的是A产品
        }
        System.out.println("Producer produced: " + item);
        lock.notify(); // 通知消费者可以消费了
    }
}

// Consumer.java
class Consumer {
    private Object item;
    private final Object lock = new Object();

// 消费方法，这里只是一个模拟
    public synchronized void consume() {
        while (item == null) { // 如果当前没有生产的产品
            try {
                lock.wait(); // 等待通知，直到有产品可消费
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        System.out.println("Consumer consumed: " + item);
        lock.notifyAll(); // 通知所有线程，产品已经被消费
    }
}
```

2. **启动多线程**

在`Main`类中，创建两个线程分别执行生产者和消费者。

```java
public class Main {
    public static void main(String[] args) {
        Producer producer = new Producer();
        Consumer consumer = new Consumer();

// 启动生产者和消费者
        Thread producerThread = new Thread(producer, "Producer"));
        Thread consumerThread = new Thread(consumer, "Consumer"));

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

// 关闭主线程，防止无限等待
        try {
            Thread.sleep(500); // 延迟一会再关闭主线程
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}
```

现在你已经创建了一个基本的生产者-消费者模型实例。这个例子可以帮助初学者理解和应用多线程并发编程。