3

我有一些代码:

public class MyTask implements Runnable {
    @Override
    public void run() {
        // Some code

        Thread.sleep();

        // Some more code.
    }
}

ExecutorService executor = Executors.newCachedThreadPool();
List<MyTask> tasks = getTasks();
for(MyTask t : tasks)
    executor.execute(t);

executor.shutdownNow()
if(!executor.awaitTermination(30, TimeUnit.MINUTES)) {
    TimeoutException toExc = new TimeoutException("MyAPp hung after the 30 minutes timeout was reached.")   // TODO
    log.error(toExc)

    throw toExc
}

当我使用MyTask来自 的多个实例运行它时getTasks(),我变得非常神秘:

[pool-3-thread-3] INFO me.myapp.MyTask - java.lang.InterruptedException: sleep interrupted
    at java.lang.Thread.sleep(Native Method)
    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
    at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    at java.lang.reflect.Method.invoke(Method.java:606)
    ...etc.

这里的问题是没有根本原因:线程睡眠只是在某个时候“中断”。

所以我问:什么时候/为什么会被Thread.sleep()中断,我该怎么做才能找到异常的根本原因?

4

3 回答 3

2

任务正在执行的线程可以通过发出来中断

future.cancel(true);

针对从调用返回的 Future 对象executorService.submit(runnable);

如果您遇到许多此类异常,另一种可能性是整个执行程序服务已使用关闭

executorService.shutdownNow();

没有直接的方法可以找出哪个线程实际打开了interrupted标志的操作。

于 2014-08-07T15:37:57.937 回答
0

参考JavaDoc for Thread.sleep(),另一个 Thread 打断了你的。

抛出:
InterruptedException - 如果任何线程中断了当前线程。抛出此异常时清除当前线程的中断状态。

JavaDoc显示了InterruptedException更多详细信息:

当线程等待、休眠或以其他方式被占用,并且线程在活动之前或期间被中断时抛出。有时某个方法可能希望测试当前线程是否已被中断,如果是,则立即抛出此异常。

于 2014-08-07T15:37:41.910 回答
0

作为一个黑客,你可以,而不是实现Runnableextend Thread。然后,您可以interrupt在转发调用之前覆盖并获取堆栈跟踪。

我不建议在最终代码中使用此方法,但在跟踪奇怪的中断时,这可能是唯一的方法。

public class InterruptAwareThread extends Thread {
    volatile String interruptedStack = null;
    @Override
    public void interrupt () {
        StringWriter s = new StringWriter();
        new Exception().printStackTrace(new PrintWriter(s));
        interruptedStack = s.toString();
        super.interrupt();
    }
}
于 2014-08-07T16:22:40.520 回答