Java多线程编程实例分析

原创短命女 2025-03-18 04:18 59阅读 0赞

Java多线程编程是Java语言中一种重要的并发机制。下面我们将通过一个实例来深入理解。

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

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

```java
class Producer extends Thread {
    private int count = 0;
    
    public Producer(String name) {
        super(name);
    }
    
    @Override
    public void run() {
        while (count < 10) { // 生产10个商品
            synchronized (this) { // 使用synchronized关键字保证生产与消费的同步
                count++;
                System.out.println(getName() + ": Produce " + count);
                
                // 模拟耗尽，引发消费者线程等待
                if (count == 5) {
                    try {
                        synchronized (this) { // 处理阻塞
                            wait();
                            System.out.println(getName() + ": Wake up after waiting");
                            
                            // 模拟恢复，引发生产者线程唤醒
                            count = 0;
                            notifyAll();
                            System.out.println(getName() + ": Notify all after waking up");
                        }
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    } finally {
                        // 线程重新开始
                        start();
                    }
                }
            }
        }
    }
}

class Consumer extends Thread {
    private int count = 0;
    
    public Consumer(String name) {
        super(name);
    }
    
    @Override
    public void run() {
        while (count < 10) { // 消费10个商品
            synchronized (this) { // 使用synchronized关键字保证生产与消费的同步
                count++;
                System.out.println(getName() + ": Consume " + count);
                
                // 模拟耗尽，引发生产者线程等待
                if (count == 5) {
                    try {
                        synchronized (this) { // 处理阻塞
                            wait();
                            System.out.println(getName() + ": Wake up after waiting");
                            
                            // 模拟恢复，引发消费者线程唤醒
                            count = 0;
                            notifyAll();
                            System.out.println(getName() + ": Notify all after waking up");
                        }
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    } finally {
                        // 线程重新开始
                        start();
                    }
                }
            }
        }
    }
}
```

在这个例子中，我们创建了两个线程：生产者（Producer）和消费者（Consumer）。生产者负责生成商品，并通过synchronized关键字同步；消费者负责消费商品，也通过synchronized关键字同步。

当商品耗尽时，消费者会引发生产者等待。然后，生产者在恢复后会唤醒消费者。这个过程模拟了典型的生产-消费模型。