线程执行者（九）执行者取消一个任务

执行者取消一个任务

当你使用执行者工作时，你不得不管理线程。你只实现runnable或 callable任务和把它们提交给执行者。执行者负责创建线程，在线程池中管理它们，当它们不需要时，结束它们。有时候，你想要取消已经提交给执行者 的任务。在这种情况下，你可以使用future的cancel()方法，它允许你做取消操作。在这个指南中，你将学习如何使用这个方法来取消已经提交给执行者的任务。

准备工作…

这个指南的例子使用eclipse ide实现。如果你使用eclipse或其他ide，如netbeans，打开它并创建一个新的java项目。

如何做…

按以下步骤来实现的这个例子:

1.创建task类，指定实现callable接口，并参数化为string类型。实现call()方法，写入一条信息到控制台，并使这个线程在循环中睡眠100毫秒。

<code>1</code>

<code>public</code> <code>class</code> <code>task </code><code>implements</code> <code>callable&lt;string&gt; {</code>

<code>2</code>

<code>@override</code>

<code>3</code>

<code>public</code> <code>string call() </code><code>throws</code> <code>exception {</code>

<code>4</code>

<code>while</code> <code>(</code><code>true</code><code>){</code>

<code>5</code>

<code>system.out.printf(</code><code>"task: test\n"</code><code>);</code>

<code>6</code>

<code>thread.sleep(</code><code>100</code><code>);</code>

<code>7</code>

<code>}</code>

<code>8</code>

2.实现示例的主类，创建main类，实现main()方法。

<code>public</code> <code>class</code> <code>main {</code>

<code>public</code> <code>static</code> <code>void</code> <code>main(string[] args) {</code>

3. 使用executors类的newcachedthreadpool()方法创建threadpoolexecutor对象。

<code>threadpoolexecutor executor=(threadpoolexecutor)executors.newcachedthreadpool();</code>

4.创建task对象。

<code>task task=</code><code>new</code> <code>task();</code>

5.使用submit()方法提交任务给执行者。

<code>system.out.printf(</code><code>"main: executing the task\n"</code><code>);</code>

<code>future&lt;string&gt; result=executor.submit(task);</code>

6.使主任务睡眠2秒。

<code>try</code> <code>{</code>

<code>timeunit.seconds.sleep(</code><code>2</code><code>);</code>

<code>} </code><code>catch</code> <code>(interruptedexception e) {</code>

<code>e.printstacktrace();</code>

7.使用通过submit()方法返回的future对象result的cancel()方法，取消任务的执行。传入true值作为cancel()方法的参数。

<code>system.out.printf(</code><code>"main: canceling the task\n"</code><code>);</code>

<code>result.cancel(</code><code>true</code><code>);</code>

8.将iscancelled()方法和isdone()的调用结果写入控制台，验证任务已取消，因此，已完成。

<code>system.out.printf(</code><code>"main: canceled: %s\n"</code><code>,result.iscanceled());</code>

<code>system.out.printf(</code><code>"main: done: %s\n"</code><code>,result.isdone());</code>

9.使用shutdown()方法结束执行者，写入信息（到控制台）表明程序结束。

<code>executor.shutdown();</code>

<code>system.out.printf(</code><code>"main: the executor has finished\n"</code><code>);</code>

它是如何工作的…

当你想要取消你已提交给执行者的任务，使用future接口的cancel()方法。根据cancel()方法参数和任务的状态不同，这个方法的行为将不同：

如果这个任务已经完成或之前的已被取消或由于其他原因不能被取消，那么这个方法将会返回false并且这个任务不会被取消。

如果这个任务正在等待执行者获取执行它的线程，那么这个任务将被取消而且不会开始它的执行。如果这个任务已经正在运行，则视方法的参数情况而定。 cancel()方法接收一个boolean值参数。如果参数为true并且任务正在运行，那么这个任务将被取消。如果参数为false并且任务正在运行，那么这个任务将不会被取消。

以下截图显示该示例的执行输出：

不止这些…

如果你使用future对象的get()方法来控制一个已被取消的任务，这个get()方法将抛出cancellationexception异常。

参见

在第4章，线程执行者中的执行者执行返回结果的任务指南