如何处理:在循环中调用'Thread.sleep()',可能是忙等待

mas*_*y88 7 java sleep thread-safety thread-sleep

伙计们如何处理这样的代码和警告?

private void listenOnLogForResult() {
    String logs = "";
    int timeCounter = 1;
    while (logs.isEmpty()) {
        try {
            timeCounter++;
            Thread.sleep(2000); // Wait 2 seconds
        } catch (InterruptedException e) {
            log.error(e.getLocalizedMessage(), e);
        }
        if (timeCounter < 30) {
            logs = checkLogs()
        } else {
            logs = "Time out";
        }
    }
}
Run Code Online (Sandbox Code Playgroud)

我需要暂停当前线程 2 秒钟以等待文件被填充,但我的 Intelij 在这里出现了问题。 在此处输入图片说明 而且我从声纳中收到错误:SonarLint:重新中断此方法或重新抛出“InterruptedException”。

我已经尝试过很多ExecutorService,但它总是在单独的线程中运行,我需要暂停当前的线程。

请帮忙..

rzw*_*oot 8

忙等待警告

这是来自 intellij 的一个可疑的警告,因为您正在做的事情通常是直接需要的。换句话说,它正在检测一个过度使用的模式,但其使用率不能减少到 0。因此,可能正确的解决方案是告诉 intellij 在这里闭嘴。

它所关注的问题并非如此Thread.sleep。那不是问题。然而,intellij 对这种模式的检测器需要它来发现这种情况,但这并不是它所抱怨的,这可能有点难以理解。

IntelliJ 担心的是,您正在浪费周期log.isEmpty(),无缘无故地不断重新检查。这段代码while方面有问题,而不是 sleep。它更愿意看到您调用某种logs.poll()方法的代码,这些方法将等待直到它被新日志出现的行为主动唤醒。

如果这一切都在单个 java 进程中运行,那么您确实可以重写整个系统(包括重写log这里的任何内容,以及对checkLogs()方法的完全重新构想:而不是出去检查,任何正在制作日志的东西都需要改为唤醒此代码。

如果不是,您可能需要告诉 intellij 关闭它:如果没有完整的系统重新设计,您正在做的事情是不可避免的。

重新中断警告

这里有一些令人遗憾的异常处理。

一般的异常处理

不要编写catch记录某些内容并继续移动的块。这是非常糟糕的错误处理:系统的变量和字段现在处于未知状态(您刚刚捕获并记录了一些东西:当然,这意味着您不知道发生了什么条件导致这行执行发生!),并且但是代码会一直移动。“捕获异常并继续运行”风格的代码极有可能导致更多的异常:通常,在未知状态下运行的代码迟早会崩溃和烧毁。

然后,如果以相同的方式处理崩溃和烧毁(抓住它,记录它,继续前进),那么您将获得另一个崩溃和烧毁。你最终得到的代码会在遇到问题时在日志中打印186 个异常,除了第一个之外,它们都完全不相关。那是坏玉宇。

您还使调用代码完全无法恢复。异常的要点是它们需要无休止地向上冒泡:要么异常被真正知道如何处理问题的代码捕获(并且记录它并没有处理它!),你正在使它变得不可能,或者,代码异常应该一直冒泡到入口点处理程序,这是记录错误和中止入口点处理程序的正确位置。

入口点处理程序是通用模块或应用程序运行程序;开箱即用,java.exe最终调用您的psv main()方法的代码是最明显的“入口点运行器”,但还有更多:Web 框架最终将调用您的一些应该处理 Web 请求的代码:该代码of yours 类似于psv main():它是入口点,Web 框架中调用它的代码是入口点运行器。

入口点运行器有充分的理由去catch (Throwable t),并且将他们的 catch 块主要用于记录它,尽管他们通常应该记录的不仅仅是异常(例如,Web 处理程序应该记录请求详细信息,例如哪些 HTTP 参数是发送以及它是哪个路径请求,可能是标头等)。但是,任何其他代码都不应该这样做

如果您不知道该做什么并且不想考虑该异常可能意味着什么,那么正确的“无论如何,只需编译 javac”代码策略是将异常类型添加到您的throws行中。如果这不可行,catch 块中的正确代码是:

} catch (ExceptionIDoNotWantToThinkAboutRightNow e) {
    throw new RuntimeException("Uncaught", e);
}
Run Code Online (Sandbox Code Playgroud)

这将确保代码不会只是在未知状态下愉快地继续运行,并将确保您在日志中获得完整的详细信息,并确保调用代码可以捕获并处理它(如果可以),并确保任何自定义日志信息,例如因为 HTTP 请求详细信息有机会进入日志。双赢双赢。

特别是这种情况:InterruptedEx 是什么意思?

当在该 java 进程中运行的某些代码调用 时yourThread.interrupt(),这是InterruptedException可能发生的,并且不可能以任何其他方式发生。如果用户点击CTRL + C,或进入任务管理器,点击“结束进程”,或者如果你的Android手机决定是时候为你的应用程序获得了在需要别的东西的记忆-没有这些案件都不可能导致 InterruptedExceptions。您的线程只是在中途被 java 杀死(如果您想对关闭采取行动,请使用Runtime.getRuntime().addShutdownHook)。唯一的方法是让某些代码调用.interrupt(),而核心库中的任何内容都不会这样做。因此, InterruptedException 意味着您认为“在此线程上调用 .interrupt()”的含义。它是由你决定。

最常见的定义实际上是“我要求你停止”:只是很好地关闭线程。一般来说,如果你想退出整个 VM,尝试很好地关闭线程是不好的(只需调用System.shutdown- 你已经需要处理用户按下 CTRL+C,为什么要以不同的方式编写两次关闭代码?) - 但有时你只是想要一个线程停止。因此,通常放入catch (InterruptedException e)块中的最佳代码只是简单的 return;而已。不要记录任何东西:“中断”是故意的:你写的。很可能在您的代码库中没有任何地方,并且 InterruptedException 没有实际意义:它永远不会发生。

在您的特定代码中,如果您的代码决定停止记录器线程会发生什么,记录器线程会将某些内容记录到错误日志中,然后缩短其 2 秒等待时间以立即检查日志,然后继续运行。这听起来完全没用。

但是,这意味着任何你想要的。如果您希望用户能够点击“立即强制检查日志”按钮,那么您可以定义中断日志记录线程只是缩短 2 秒的时间(但是只有一个带有注释的空 catch 块,解释说明这就是你设计它的方式,显然不要记录它)。如果您还需要一个按钮来“停止日志记录线程”,请使用跟踪“运行”状态的 AtomicBoolean:当点击“停止日志刷新”按钮时,将 AB 设置为“假”,然后中断线程:然后您粘贴的代码需要检查 AB 并return;关闭线程(如果是)false