5

我创建的代码创建了一个 Callable 实例并使用 ExecutorService 创建了一个新线程。如果线程未完成执行，我想在一定时间后终止该线程。在浏览了 jdk 文档后，我意识到 Future.cancel() 方法可以用来停止线程的执行，但令我沮丧的是它不起作用。当然，future.get() 方法会在规定的时间（在我的情况下是 2 秒）之后向线程发送中断，甚至线程正在接收这个中断，但是只有在线程完成执行后才会发生这种中断完全地。但我想在 2 秒后杀死线程。

谁能帮助我如何实现这一目标。

测试类代码：

====================================

public class TestExecService {

      public static void main(String[] args) {

          //checkFixedThreadPool();
          checkCallablePool();

          }

      private static void checkCallablePool()
      {
          PrintCallableTask task1 = new PrintCallableTask("thread1");

          ExecutorService threadExecutor = Executors.newFixedThreadPool(1);
          Future<String> future = threadExecutor.submit(task1);

          try {
                System.out.println("Started..");
                System.out.println("Return VAL from thread ===>>>>>" + future.get(2, TimeUnit.SECONDS));
                System.out.println("Finished!");
            }
          catch (InterruptedException e) 
          {
            System.out.println("Thread got Interrupted Exception ==============================>>>>>>>>>>>>>>>>>>>>>>>>>");
            //e.printStackTrace();
          }
          catch (ExecutionException e) 
          {
            System.out.println("Thread got Execution Exception ==============================>>>>>>>>>>>>>>>>>>>>>>>>>");
          }
          catch (TimeoutException e)
          {
            System.out.println("Thread got TimedOut Exception ==============================>>>>>>>>>>>>>>>>>>>>>>>>>");
            future.cancel(true);
          }

          threadExecutor.shutdownNow();

      }
}

可调用类代码：

===================================================================
package com.test;

import java.util.concurrent.Callable;

public class PrintCallableTask implements Callable<String> {

      private int sleepTime;
      private String threadName;

    public PrintCallableTask(String name)
    {
        threadName = name;
        sleepTime = 100000;     
    }

    @Override
    public String call() throws Exception {

        try {
              System.out.printf("%s going to sleep for %d milliseconds.\n", threadName, sleepTime);
              int i = 0;

              while (i < 100000)
              {
                  System.out.println(i++);
              }


              Thread.sleep(sleepTime); // put thread to sleep
              System.out.printf("%s is in middle of execution \n", threadName);

            } catch (InterruptedException exception) {
              exception.printStackTrace();
            }


            System.out.printf("%s done sleeping\n", threadName);

            return "success";
    }

}
4

2 回答 2

9

你的代码做的一切都是正确的。Thread.isInterrupted唯一的问题是您没有检查while循环。线程获取消息的唯一方法是获取Thread.sleep将立即抛出的阻塞调用InterruptedException。如果循环很长，则可能需要一些时间。这正是您的代码有点反应迟钝的原因。

例如，每 10,000 次迭代检查一次中断状态：

while (i < 100000) {

    if (i % 10000 == 0 && Thread.currentThread().isInterrupted())
        return "fail";

    System.out.println(i++);
}

InterruptedException适用于冗长的阻塞方法。Thread.isInterrupted是为一切。

于 2012-11-29T23:17:51.563 回答
4

cancel()只是要求interrupt()已经执行的线程。

http://docs.oracle.com/javase/tutorial/essential/concurrency/interrupt.html：

中断是对线程的指示，它应该停止正在做的事情并做其他事情。由程序员决定线程如何响应中断，但线程终止是很常见的。

中断的线程只会抛出InterruptedException

当一个线程正在等待、休眠或以其他方式暂停很长时间并且另一个线程使用 Thread 类中的 interrupt() 方法中断它时。

因此，您需要在执行线程时明确地使作业代码意识到可能的中断。

另请参阅如果我不是，谁在调用 Java 线程的 interrupt() 方法？.

另请参阅如何取消 Java 8 可完成的未来？因为只有 Java 8 才成熟的 Java 期货。

于 2012-11-29T13:36:21.217 回答