Executor

桑鱼

发布于 2020-04-23 15:33:49

3630

发布于 2020-04-23 15:33:49

JavaSE5 的 java.util.concurrent 包中的执行器( Executor ) 管理Thread对象。从而简化了并发编程。 Executor在客户端和任务执行之间提供了一个间接层；与客户端直接执行任务不同，这个中介对象将执行任务。 Executor允许你管理异步任务的执行，而无须显式地管理线程的生命周期。Executor在JavaSE5/6中是启动任务的优选方法 ---节选《Java编程思想》

CachedThreadPool()创建 ExecutorService

newCachedThreadPool()将为每个任务都创建一个线程

 ExecutorService exec = Executors.newCachedThreadPool();

源码

public static ExecutorService newCachedThreadPool() {
        return new ThreadPoolExecutor(0, Integer.MAX_VALUE,
                                      60L, TimeUnit.SECONDS,
                                      new SynchronousQueue<Runnable>());
}

FixedThreadPool()创建 ExecutorService

FixedThreadPool预先执行代价高昂的线程分配，限制线程的数量，不需要为每个任务都固定地付出创建线程的开销，需要线程的处理器，通过直接从池中获取线程。在任何线程池中，现有线程在可能的情况下，都会被自动复用

 ExecutorService exec = Executors.newFixedThreadPool(5)

SingleThreadExecutor()创建 ExecutorService

SingleThreadExecutor 就像线程数量为1的 FixedThreadPool 。如果希望在另一个线程中连续运行任务可以使用，例如监听进入套接字连接的任务或者是更新本地、远程日志的小任务。如果想SingleThreadExecutor中提交了多个任务，那么这些任务将会排队，每个任务都会在下一个任务开始之前运行结束，所有任务都使用相同的线程

 ExecutorService exec = Executors.newSingleThreadExecutor(5)

示例

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

/**
 * Executor用法
 * User: peng
 * Date: 2020/4/16
 * Time: 上午10:56
 */
public class TestExecutor {
    public static void main(String[] args) {
        /**
         * ExecutorService（具有服务生命周期的Executor，例如关闭）知道如何构建恰当的上下文来执行Runnable对象
         * CachedThreadPool为每个任务都创建一个线程
         * ExecutorService是使用静态Executor方法创建的，常见的情况是创建单个的Executor用来创建和管理系统中的所有任务
         */
        ExecutorService exec = Executors.newCachedThreadPool();
        for(int i = 0; i < 5; i++){
            exec.execute(new LiftOff());
        }
        exec.shutdown(); // 对shutdown的调用可以防止新任务提交给Executor，运行完Executor中所有任务后会尽快退出
        System.out.println("主线程");
    }
}

class LiftOff implements Runnable{

    protected int countDown = 10;
    private static int taskCount = 0; // taskCount是statis的，与实例无关
    private final int id = taskCount++; // 用来区分任务的多个实例，是final的一旦被初始化之后就不会被修改
    public LiftOff(){}
    public LiftOff(int countDown){
        this.countDown = countDown;
    }

    public String status(){
        return "#" + id + "(" + (countDown > 0 ? countDown : "Liftoff!") + "), ";
    }

    public void run() {
        while (countDown-- > 0){ // run方法总会有某种形式的循环，使得任务一直运行下去直到不再需要，所以要设定跳出循环的条件
            System.out.println(status());
            Thread.yield(); // 让出线程，可以将CPU从一个线程转移给另一个线程
        }
    }
}

本文参与腾讯云自媒体同步曝光计划，分享自作者个人站点/博客。

如有侵权请联系 cloudcommunity@tencent.com 删除

缓存