使用Java多线程时的同步问题案例

原创 Myth丶恋晨 2024-10-14 22:06 64阅读 0赞

在Java多线程编程中，同步问题是常见的挑战。以下是一个简单的同步问题案例：

案例：生产者-消费者模型

1. 生产者（Producer）类：
```java
class Producer extends Thread {
    private int count = 0;
    private SharedResource resource;

public Producer(SharedResource resource) {
        this.resource = resource;
    }

@Override
    public void run() {
        while (true) {
            resource.addCount(count++);
            try {
                // 模拟生产过程需要的等待时间
                Thread.sleep(100);
            } catch (InterruptedException e) {
                e.printStackTrace();
                break;
            }
        }
    }
}
```
2. 消费者（Consumer）类：
```java
class Consumer extends Thread {
    private SharedResource resource;

public Consumer(SharedResource resource) {
        this.resource = resource;
    }

@Override
    public void run() {
        while (true) {
            int count = resource.consumeCount();
            if (count > 0) {
                System.out.println("Consumed count: " + count);
            } else {
                // 模拟资源耗尽的情况，可以使用阻塞或者超时机制
                try {
                    Thread.sleep(500); // 超时睡眠
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        }
    }
}
```
3. 共享资源（SharedResource）类：
```java
class SharedResource {
    private int count = 0;

public synchronized void addCount(int count) {
        this.count += count;
        notifyAll(); // 通知所有等待的线程
    }

public synchronized int consumeCount() {
        if (count > 0) {
            count--;
            return count;
        } else {
            return 0; // 资源耗尽，返回0
        }
    }
}
```
在这个例子中，生产者和消费者通过共享的资源进行通信。同步机制（如synchronized关键字）保证了在任何时候只有一个线程可以访问资源。