java - TimeLimiter 的 callWithTimeout 不起作用？

Question

我试图在 Guava 库的帮助下停止/取消我的线程，但它不起作用。

长callTimeout = 1L;

ExecutorService callTimeoutPool= Executors.newSingleThreadExecutor( new ThreadFactoryBuilder().setNameFormat("name").setDaemon(true).build());
LOGGER.log(Level.INFO, "[ TimeoutImpl : timedCall ] currentThread name = {0}", new Object[]{Thread.currentThread().getName()});

try
{
     new SimpleTimeLimiter().callWithTimeout(new Callable(){
     @Override
     public Object call()
     {
          int i=0;
          while(true)
          {
               System.out.println(i++);
               if(false)
                    break;
               }
               return true;
               }
           }, callTimeout, TimeUnit.MILLISECONDS, true);
}
catch(InterruptedException e)
{
     LOGGER.log(Level.SEVERE, "[ TimeoutImpl : timedCall ]  InterruptedException" ,e );
     Thread.currentThread().interrupt();
     callTimeoutPool.shutdownNow();
}
catch(Exception e)
{
     LOGGER.log(Level.SEVERE, "[ TimeoutImpl : timedCall ]  Exception" ,e );
     Thread.currentThread().interrupt();
     callTimeoutPool.shutdownNow();
}

我尝试了 Future.cancel 也不起作用，请帮我解决这个问题。谢谢。

Answer 1

Interruption is a cooperative mechanism. When one thread interrupts another, the interrupted thread does not necessarily stop what it is doing immediately.

要响应中断，您的 call 实现必须调用响应中断的方法(例如 CountDownLatch.await)或通过 手动检查中断Thread.interrupted 或 isInterrupted。