如何在Java executor类中停止所有可运行线程？

Question

final ExecutorService executor = Executors.newFixedThreadPool(1);
final Future<?> future = executor.submit(myRunnable);
executor.shutdown();
if(executor.awaitTermination(10, TimeUnit.SECONDS)) {
  System.out.println("task completed");
}else{
  System.out.println("Executor is shutdown now");
}

//MyRunnable method is defined as task which I want to execute in a different thread.

这是run执行程序类的方法：

public void run() {
try {
     Thread.sleep(20 * 1000);
} catch (InterruptedException e) {
 // TODO Auto-generated catch block
 e.printStackTrace();
}}

在这里，它等待20第二秒，但是当我运行代码时，它将引发异常：

java.lang.InterruptedException: sleep interrupted
at java.lang.Thread.sleep(Native Method)

我无法关闭中的并发线程破坏Java Executor class。这是我的代码流：

• 用Java执行程序类创建一个新线程来运行某些任务，即用 MyRunnable
• executor 等待10秒以完成任务。
• 如果任务已完成，则可运行线程也将终止。
• 如果任务未在10秒内完成，则executor类应终止线程。

除了在最后一个场景中终止任务以外，其他所有操作都正常。我该怎么办？

Answer 1

该shutDown()方法只是防止其他任务被调度。相反，您可以在中调用shutDownNow()并检查线程是否中断Runnable。

// in your Runnable...
if (Thread.interrupted()) {
  // Executor has probably asked us to stop
}

根据您的代码，一个示例可能是：

final ExecutorService executor = Executors.newFixedThreadPool(1);
executor.submit(new Runnable() {
  public void run() {
    try {
      Thread.sleep(20 * 1000);
    } catch (InterruptedException e) {
      System.out.println("Interrupted, so exiting.");
    }
  }
});

if (executor.awaitTermination(10, TimeUnit.SECONDS)) {
  System.out.println("task completed");
} else {
  System.out.println("Forcing shutdown...");
  executor.shutdownNow();
}