ExecutorService workStealingPool和cancel方法

Question

你能想一想为什么这段代码不起作用并且总是输出“finished”，但是第二个示例却没有任何问题地工作。我正在使用最新的JDK(8U45)。

public static class MyClass implements Runnable {

        @Override
        public void run() {
            try {
                Thread.sleep(2000);
            } catch (InterruptedException ex) {
                System.out.println("Interrupted");
                return;
            }
            System.out.println("Finished");
        }

        public static void main(String[] args) {
             // spot the difference ->
             ExecutorService executorService = Executors.newWorkStealingPool(4);
             Future future = executorService.submit(new MyClass());
             Thread.sleep(100);
             future.cancel(true);
        }
    }

下面的示例完美无缺：

public static class MyClass implements Runnable {

        @Override
        public void run() {
            try {
                Thread.sleep(2000);
            } catch (InterruptedException ex) {
                System.out.println("Interrupted");
                return;
            }
            System.out.println("Finished");
        }

        public static void main(String[] args) {
             ExecutorService executorService = Executors.newSingleThreadExecutor();
             Future future = executorService.submit(new MyClass());
             Thread.sleep(100);
             future.cancel(true);
        }
    }

编辑：添加返回和更新的睡眠时间和另一个例子。

Answer 1

没有办法在Java强行终止一个线程。（20年前，Java 1.0试图提供这一点，但结果是行不通的；试图做到这一点的方法被否决了，没有任何替代方法。）

您作为Runnable的作者，负责通过干净利落地终止您自己的run方法来正确地响应中断。在您的示例中，应该在catch-block中退出run方法，但您没有退出；让方法的逻辑继续通过catch-block。因此，即使线程中断，也始终执行run方法的最后一条语句。

Answer 2

比我原先想象的要简单。问题是Work-Steeting-Pool在内部使用ForkJoinPool,而ForkJoinTask不支持cancel（true）,因此在任务启动后不可能取消任务。

请参阅javadoc文档（http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/forkjointask.html）：

   mayInterruptIfRunning - this value has no effect in the default implementation 
   because interrupts are not used to control cancellation.