使用Thread.sleep()时的Java同步问题实例

原创 ╰半橙微兮° 2024-09-19 22:48 46阅读 0赞

在Java中，`Thread.sleep()`方法用于让当前线程暂停执行一段时间。这在多线程场景中可能会引发同步问题。

以下是一个简单的例子，展示了`Thread.sleep()`可能导致的问题：

```java
class Counter {
    int count = 0;

synchronized void increment() {
        count++;
        notifyAll(); // 通知所有等待的线程
    }

synchronized void decrement() {
        if (count > 0) {
            count--;
            notifyAll();
        }
    }

public int getCount() {
        return count;
    }
}

public class SleepingCounter {
    private Counter counter;

public SleepingCounter(int initialCount) {
        counter = new Counter();
        counter.increment(); // 初始化计数
        counter.getCount();  // 确保计数已经更新
    }

public void addSleepTime(long sleepTime) {
        Thread.sleep(sleepTime); // 模拟睡眠

try {
            // 虽然线程被睡眠，但通知机制仍然有效
            counter.decrement();
        } catch (InterruptedException e) {
            e.printStackTrace(); // 如果线程在减计过程中被中断，这将抛出异常
        }
    }

public int getCount() {
        return counter.getCount();
    }
}

public class Main {
    public static void main(String[] args) {
        SleepingCounter counter = new SleepingCounter(10);

for (int i = 0; i < 5; i++) { // 模拟5次操作
            counter.addSleepTime(1000); // 每次操作后睡眠1秒

try {
                System.out.println("Count after operation " + (i + 1)) + ": " + counter.getCount());
                Thread.sleep(2000); // 防止控制台输出太快，导致后面的操作无法正确显示
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }

System.out.println("Final count: " + counter.getCount()));
    }
}
```

在这个例子中，`SleepingCounter`类的成员变量`counter`是一个共享资源（线程同步对象）。每次操作后，线程都会睡眠一段时间。然而，由于通知机制的存在，即使线程被睡眠，计数仍然有可能减小。

在最后，当所有预期的操作完成后，我们可以看到最终的计数值。这展示了Java中多线程同步问题的一个实例。