关于 Executor 和 ExecutorService

2020-09-11 15:12:24 浏览数 (1)

一、Executor:

  • 是一个接口
  • 用于执行提交的任务
  • 解耦任务提交和执行(线程的创建及调度)

Executor的实现可以根据实际需求延展不同的逻辑:

1、对于提交的任务同步或者异步执行,如下同步执行:

代码语言:javascript复制
class ThreadPerTaskExecutor implements Executor {
   public void execute(Runnable r) {
     new Thread(r).start();
}

2、另起线程执行任务,如下:

代码语言:javascript复制
 class ThreadPerTaskExecutor implements Executor {
     public void execute(Runnable r) {
     new Thread(r).start();
 }

3、对于执行的任务添加限制:

代码语言:javascript复制
class SerialExecutor implements Executor {
   final Queue<Runnable> tasks = new ArrayDeque<Runnable>();
   final Executor executor;
   Runnable active;

   SerialExecutor(Executor executor) {
     this.executor = executor;
   }

   public synchronized void execute(final Runnable r) {
     tasks.offer(new Runnable() {
       public void run() {
         try {
           r.run();
         } finally {
           scheduleNext();
         }
       }
     });
     if (active == null) {
       scheduleNext();
     }
   }

   protected synchronized void scheduleNext() {
     if ((active = tasks.poll()) != null) {
       executor.execute(active);
     }
   }
 }}

二、ExecutorService:

  • 任务执行器
  • 提供任务终止方法
  • 返回Future用以跟踪任务执行结果

1、可以被关闭,也就意味着执行器不再接受新任务

shutdown:等待已提交的任务执行完毕后关闭

shutdownNow:阻止等待的任务开始并停止当前运行的任务

对于不再使用的 ExecutorService 需要及时关闭以释放资源

2、submit:创建并返回 Future 对象,用以取消任务或者等待任务执行完成

3、invokeAny、invokeAll:批处理任务,invokeAny 等待任务中任一任务执行完成即返回,invokeAll 等待所有任务执行完成即返回

4、Executors:ExecutorService 工厂类

0 人点赞