2

我试图让我的主线程产生一个新线程，并在一段时间后引发中断标志。当它这样做时，生成的线程应该看到该标志并自行终止。

主线程看起来像这样：

final Thread t = new Thread()
{
    @Override
    public void run()
    {
        f();
    }
};
t.start();
try
{
    t.join(time);
    t.interrupt();
    if(t.isAlive())
    {
        t.join(allowance);
        if(t.isAlive())
            throw new Exception();
    }
}
catch(Exception e)
{
    System.err.println("f did not terminate in the alloted time");
}

生成的线程在其代码中散布着以下内容：

if(Thread.interrupted()) return;

当我处于调试模式时，一切正常。中断标志由主线程引发并被衍生线程捕获。但是，在常规运行模式下，无论我设置多长时间，生成的线程似乎都没有收到中断标志。

有谁知道我做错了什么？

注意：我使用的是 Ubuntu，而且我对任何 Linux 都是新手。问题可能出在操作系统上吗？我没有在任何其他操作系统上测试过代码。

4

4 回答 4

4

以下是我的猜测：

  • 当主线程调用t.interrupt();时，t 线程已经完成执行。
  • 当主线程t.interrupt();在 t 线程中调用时，不再调用检查interrupted()标志。
  • 由于运行代码，您得到了异常？您是否在“允许”时间之后在代码中抛出异常，或者您有其他类似ThreadInterruptedException或类似的异常？尝试编写捕获异常的消息...
于 2009-05-16T08:42:41.980 回答
0

看起来好像在 f() 中没有达到 Thread.interrupted() 调用。

您在 Debug 和 Run 模式下看到的不同行为可能是由于竞态条件造成的。

于 2009-05-16T08:25:27.390 回答
0

你有 Thread.interrupted() 的嵌套检查吗？该方法清除中断标志，因此第二次调用返回 false。您可以改用 isInterrupted() 。

于 2009-05-16T08:58:38.980 回答
0

我建议您考虑使用 ExecutorService，它旨在执行此类操作，并且可以通过其他方式帮助您。

ExecutorService service = Executors.newCachedThreadPool();
Future<ResultType> future = service.submit(new Callable<ResultType() {
   public ResultType call() throws Exception {
      // do soemthing
      return (ResultType) ...;
   }
);
// do anything you like until you need to result.
try {
   ResultType result = future.get(5, TimeUnit.SECONDS);
} catch (TimeoutException timedOut) {
  // handle exception
  // cancel the task, interrupting if still running.
  result.cancel(true);
} catch (ExecutionException taskThrewAnException) {
  // handle exception
}
// when you have finished with the service, which is reusable.
service.shutdown();
于 2009-05-16T19:25:58.737 回答