停止一个线程/多个线程在崩溃后会对自身调用中断？

Question

我目前正在从一个服务运行一个线程来做一些后台工作。现在存在线程崩溃或者我想从服务中断线程的可能性。那我该怎么：

1. 实际停止线程，（硬）
2. 捕获异常并调用有关崩溃的服务
3. 如果在睡眠时中断，则处理InterruptedException()
4. 线程是否为Thread.IsInterrupted是检测线程是否停止的好方法吗？

到目前为止，我所做的工作如下：

@Override
public void run() {
    try {
        while (!Thread.currentThread().isInterrupted()) {
            doMyBackgroundWork();
            sleep();
        }
    }catch(Exception e){
        ExceptionHandler.logAndSendException(e);
        Thread.currentThread().interrupt();
        if(crashedListener != null){
            crashedListener.onThreadCrashed();
        }
    }
    LOG.i("Thread stops now.");
}

private void sleep() {
    try {
        sleep(frequency);
    } catch (InterruptedException e) {
        //what to do here? it can happen because I stopped it myself 
    }
}

所以一开始我运行我的线程直到它被中断。如果出现任何异常，我想启动一个新线程，因此我的服务实现了一个侦听器接口，一旦抛出异常，我就调用它。我知道不鼓励捕获所有内容，但我需要知道线程是否停止，而不需要一直轮询Thread.isAlive（）。

除了我上面的四个问题之外：

• 我的代码是否可靠，是否符合我的需要？
• 在线程本身上调用中断可以吗？

谢谢！

Answer 1

您实际上并没有中断您自己的线程，因为catch块在while循环之外。因此，任何异常都将立即停止执行。

中断本质上只是一个请求（通常来自另一个线程），要求停止做你正在做的事情。线程可以自由地忽略它，并继续做它正在做的事情。通常情况下，您必须抛出一个异常来响应中断，或者以其他方式停止执行，例如从循环中中断（您需要在//what to do here？注释中这样做）。有些库方法是“响应中断”的，这意味着如果线程被中断，它们会抛出异常，例如thread.sleep()，您很可能在sleep调用中使用它。

我推荐在实践中选择Java并发。在优秀的并发材料中，有一章是关于中断的，非常有帮助。

编辑：我会删除你中断自己线程的代码。您还需要将InterruptedException作为运行时异常重新抛出，以脱离执行循环。通常，人们会创建一个扩展RuntimeException的新异常，类似于MyInterruptedException。然后，您可以将它添加到循环周围的catch块中，这样您就可以知道线程何时中断，何时执行失败。

作为一个通用示例，您可以执行如下操作：

public void run() {
    try {
        while (true) {
            // check for interrupts in the loop, or somewhere in the work method
            if (Thread.interrupted()) {
                throw new MyInterruptedException("Important thread interrupted.");
            }
            doMyBackgroundWork();
            sleep();
        }
    }
    catch(Exception e){
        ExceptionHandler.logAndSendException(e);
        if(crashedListener != null){
            crashedListener.onThreadCrashed();
        }
    }
    catch(MyInterruptedException i) {
        LOG.i("Execution stopping because of interrupt.");
    }
}

private void sleep() {
    try {
        sleep(frequency);
    } catch (InterruptedException e) {
        throw new MyInterrptedException(e);
    }
}