如何避免线程内循环调用Thread.sleep时触发忙等待警告

警告说明 #

IDE触发该警告是保守提示你避免循环内过短sleep导致的忙等资源浪费，你当前代码里sleep间隔为1秒本身不存在性能问题，只是误报，以下是几种消除警告的实现方案：

方案1：添加注解直接抑制警告（改动最小，适配原有逻辑）

只需要在对应方法或sleep代码段前加@SuppressWarnings("BusyWait")注解即可：

@SuppressWarnings("BusyWait")
public void foo(AtomicBoolean close){
    new Thread(() -> {
        try{
            System.out.println("foo started");
            while(!close.get()){
                System.out.print("working");
                // 待执行的业务代码段

                // 等待1秒后重新执行相同逻辑
                try{ Thread.sleep(1_000); /*1sec*/ }catch(Exception ignored){}
            }
        }catch(Exception e){
            e.printStackTrace();
        }
        System.out.println("foo stopped");
    }, "fooThread").start();
}

方案2：使用ScheduledExecutorService实现周期性任务（最规范的官方推荐方案）

Java标准库提供的调度线程池专门用于实现固定间隔/延迟的任务逻辑，完全不会触发此类警告：

// 全局定义单线程调度池，和原有单线程逻辑对齐
private final ScheduledExecutorService scheduler = Executors.newSingleThreadScheduledExecutor();

public void foo(AtomicBoolean close){
    System.out.println("foo started");
    // 提交固定延迟任务：执行完上一次任务后等待1秒执行下一次
    scheduler.scheduleWithFixedDelay(() -> {
        if (close.get()) {
            System.out.println("foo stopped");
            throw new CancellationException("任务主动终止");
        }
        System.out.print("working");
        // 待执行的业务代码段
    }, 0, 1, TimeUnit.SECONDS);
}

// 应用退出时记得关闭线程池避免资源泄漏
public void shutdown() {
    scheduler.shutdown();
}

方案3：使用wait/notify机制（支持停止信号即时响应）

如果需要close标记修改后立刻终止线程，不用等sleep的1秒间隔结束，可以用锁的wait机制替代sleep：

private final Object lock = new Object();

public void foo(AtomicBoolean close){
    new Thread(() -> {
        try{
            System.out.println("foo started");
            while(!close.get()){
                System.out.print("working");
                // 待执行的业务代码段

                synchronized (lock) {
                    // 最多等待1秒，收到notify信号会提前唤醒
                    lock.wait(1000);
                }
            }
        }catch(InterruptedException e){
            Thread.currentThread().interrupt();
        }catch(Exception e){
            e.printStackTrace();
        }
        System.out.println("foo stopped");
    }, "fooThread").start();
}

// 修改close标记的逻辑需要同步唤醒等待线程
public void stopTask() {
    synchronized (lock) {
        close.set(true);
        lock.notifyAll();
    }
}

内容的提问来源于stack exchange，提问作者KunLun