线程执行者(十二)执行者控制被拒绝的任务

声明:本文是《 Java 7 Concurrency Cookbook 》的第四章,作者: Javier Fernández González     译者:许巧辉     校对:方腾飞,叶磊

执行者控制被拒绝的任务

当你想要结束执行者的执行,你使用shutdown()方法来表明它的结束。执行者等待正在运行或等待它的执行的任务的结束,然后结束它们的执行。

如果你在shutdown()方法和执行者结束之间,提交任务给执行者,这个任务将被拒绝,因为执行者不再接收新的任务。ThreadPoolExecutor类提供一种机制,在调用shutdown()后,不接受新的任务。

在这个指南中,你将学习如何通过实现RejectedExecutionHandler,在执行者中管理拒绝任务。

准备工作…

这个指南的例子使用Eclipse IDE实现。如果你使用Eclipse或其他IDE,如NetBeans,打开它并创建一个新的Java项目。

如何做…

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

1.创建RejectedTaskController类,实现RejectedExecutionHandler接口。实现这个接口的rejectedExecution()方法。写入被拒绝任务的名称和执行者的名称与状态到控制台。


public class RejectedTaskController implements
RejectedExecutionHandler {
@Override
public void rejectedExecution(Runnable r, ThreadPoolExecutor executor) {
System.out.printf("RejectedTaskController: The task %s has been rejected\n",r.toString());
System.out.printf("RejectedTaskController: %s\n",executor.toString());
System.out.printf("RejectedTaskController: Terminating:%s\n",executor.isTerminating());
System.out.printf("RejectedTaksController: Terminated:%s\n",executor.isTerminated());
}

2.实现Task类,实现Runnable接口。


public class Task implements Runnable{

3.声明私有的、String类型的属性name, 用来存储任务的名称。


private String name;

4.实现这个类的构造器,初始化这个类的属性。


public Task(String name){
this.name=name;
}

5.实现run()方法,写入信息到控制台,表明这个方法开始执行。


@Override
public void run() {
System.out.println("Task "+name+": Starting");

6.等待一段随机时间。


try {
long duration=(long)(Math.random()*10);
System.out.printf("Task %s: ReportGenerator: Generating a report during %d seconds\n",name,duration);
TimeUnit.SECONDS.sleep(duration);
} catch (InterruptedException e) {
e.printStackTrace();
}

7.写入信息到控制台,表明方法的结束。


System.out.printf("Task %s: Ending\n",name);
}

8.重写toString()方法,返回任务的名称。


public String toString() {
return name;
}

9.实现这个示例的主类,通过创建Main类,并实现main()方法。


public class Main {
public static void main(String[] args) {

10.创建一个RejectedTaskController对象,管理拒绝的任务。


RejectecTaskController controller=new RejectecTaskController();

11.使用Executors类的newCachedThreadPool()方法,创建ThreadPoolExecutor。


ThreadPoolExecutor executor=(ThreadPoolExecutor) Executors.newCachedThreadPool();

12.建立执行者的拒绝任务控制器。


executor.setRejectedExecutionHandler(controller);

13.创建任务并提交它们给执行者。


System.out.printf("Main: Starting.\n");
for (int i=0; i<3; i++) {
Task task=new Task("Task"+i);
executor.submit(task);
}

14.使用shutdown()方法,关闭执行者。


System.out.printf("Main: Shutting down the Executor.\n");
executor.shutdown();

15.创建其他任务并提交给执行者。


System.out.printf("Main: Sending another Task.\n");
Task task=new Task("RejectedTask");
executor.submit(task);

16.写入信息到控制台,表明程序结束。


System.out.println("Main: End");
System.out.printf("Main: End.\n");

这是如何工作的…

以下截图显示示例的执行结果:

8

你可以看出当执行者关闭时,任务被拒绝提交。RejectecTaskController将有关于任务和执行者的信息写入到控制台。

为了管理执行者控制拒绝任务,你应该实现RejectedExecutionHandler接口。该接口有带有两个参数的方法rejectedExecution():

  • Runnable对象,存储被拒绝的任务
  • Executor对象,存储拒绝任务的执行者

每个被执行者拒绝的任务都会调用这个方法。你必须使用Executor类的setRejectedExecutionHandler()方法设置拒绝任务的处理器。

不止这些…

当执行者接收任务时,会检查shutdown()是否已经被调用了。如果被调用了,它拒绝这个任务。首先,它查找 setRejectedExecutionHandler()设置的处理器。如果有一个(处理器),它调用那个类的 rejectedExecution()方法,否则,它将抛RejectedExecutionExeption异常。这是一个运行时异常,所以你不需要 用catch语句来控制它。

参见

  • 在第4章,线程执行者中的创建一个线程执行者指南

原创文章,转载请注明: 转载自并发编程网 – ifeve.com本文链接地址: 线程执行者(十二)执行者控制被拒绝的任务

Snway

许巧辉,目前在Letv练级,平时喜欢看书,关注Java并发

Latest posts by Snway (see all)

FavoriteLoading添加本文到我的收藏
  • Trackback are closed
  • Comments (0)
  1. No comments yet.

You must be logged in to post a comment.

return top