Java多线程同步问题实例分享

原创爱被打了一巴掌 2024-11-15 21:27 9阅读 0赞

在Java多线程编程中，同步问题是常见的挑战。这里我将通过一个实际的实例来分享。

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

1. **创建两个线程：生产者（Producer）和消费者（Consumer）**。

```java
class Product {
    // 生产数据
}

class Producer extends Thread {
    private static Product product = new Product();

@Override
    public void run() {
        while (true) {  // 无限循环，模拟不断生产的场景
            product.data = "New Product Data";  // 假设产品数据是可变的

synchronized (this) {  // 使用synchronized关键字同步生产操作
                if (!isStopped()) {  // 检查线程是否被中断
                    System.out.println("Produced: " + product.data);  // 输出生产的产品信息
                    sleep(500);  // 模拟生产时间，每隔一段时间生产一次
                }
            }
        }
    }

private synchronized boolean isStopped() {
        return this.isInterrupted();
    }
}
```

2. **创建消费者线程（Consumer）**。

```java
class Consumer extends Thread {
    @Override
    public void run() {
        while (true) {  // 模拟消费者循环
            Product product = null;

synchronized (Producer.class) {  // 获取生产者的锁，进行消费操作
                if (product != null) {  // 如果之前有产品，则消费这个产品
                    System.out.println("Consumed: " + product.data);
                    break;  // 结束当前消费者循环
                } else {  // 没有产品时，睡眠一段时间等待生产
                    try {
                        sleep(1000);  // 模拟等待时间
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }
            }

if (product == null) {  // 如果当前没有产品，再次尝试获取锁
                try {
                    synchronized (Producer.class) {  // 再次尝试获取锁
                        if (product != null) {
                            System.out.println("Resumed after retry: " + product.data);
                            break;  // 结束当前消费者循环
                        }
                    }
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        }
    }
}
```

这个例子展示了如何使用Java多线程同步机制，通过synchronized关键字实现对生产者和消费者的锁管理。这样可以保证在任何时候只有一个线程能够访问共享资源。