线程池和多线程管理

**基本概念：**

一、线程池的体系结构：
>
    Executor 负责线程的使用和调度的 根接口，默认饱和策略 AbortPolicy
	|--ExecutorService  接口：线程池的主要接口。增加了返回 Future 对象
		|--ThreadPoolExecutor 线程池的实现类，可以指定饱和策略，阻塞队列
		|--ScheduledExceutorService 接口：负责线程的调度
			|--ScheduledThreadPoolExecutor：继承 ThreadPoolExecutor，实现了ScheduledExecutorService

二、工具类：Executors
> 
    ExecutorService pool = Executors.newFixedThreadPool()：创建固定大小的线程池
    ExecutorService pool = Executors.newCachedThreadPool()：缓存线程池，线程池的数量不固定，可以根据需求自动的更改数量。
    ExecutorService pool = Executors.newSingleThreadExecutor()：创建单个线程池。 线程池中只有一个线程
    ScheduledExecutorService pool = Executors.newScheduledThreadPool()：创建固定大小的线程，可以延迟或定时的执行任务
    ......

1. `Executor` 相比 `Thread` 将任务本身和任务的执行解耦。
2. `FutureTask` 是一个实现了 `Future` 接口和 `Runnable` 接口的类，它可以用于包装一个异步计算任务，可以在执行计算时提供取消任务、获取计算结果等功能。当执行批量的 `FutureTask` 的时候，`get()` 不一定获取到第一个执行完成的任务，从而阻塞主线程造成浪费。
3. `CompletionService` 解决了 `FutureTask` 的缺陷，`take()/poll()` 优先获取先完成的任务并移出该元素，`take()` 会阻塞，`poll()` 会返回 null。

- 在执行大量相互独立和同构的任务时，可以使用 `CompletionService`。
    - `CompletionService` 可以为任务的执行设置时限，主要是通过 `BlockingQueue` 的 `poll(long time，TimeUnit unit)` 为任务执行结果的取得限制时间，如果没有完成就取消任务。
    - `CompletionService` 是在线程执行完拿到结果之后放入到了 `BlockingQueue` 中的。
    - `CompletionService` 是 `BlockQueue.take()` 队列都拿完了，或者没有放入——才阻塞。
    - `CompletionService` 取出所消耗的时间是哪个最后完成任务的时间。
    
4. `CompletableFuture` 除了提供了更为好用和强大的 `Future` 特性之外，还提供了函数式编程、异步任务编排组合（可以将多个异步任务串联起来，组成一个完整的链式调用）等能力。
    ```
    thenApply // 有入参和返回参数
    thenApplyAsync
    thenAccept // 只有入参没有返回参数
    thenAcceptAsync
    acceptEither // 接收任意一个处理完的任务
    thenRun // 没有入参没有返回参数
    thenRunAsync
    thenCombine // 有序组合
    thenCombineAsync
    thenCompose // 无序组合
    thenComposeAsync
    whenComplete/handle/exceptionally // 任务执行完毕后的处理任务
    allOf().join() // 阻塞等待所有任务
    anyOf().join() // 阻塞等待任一任务
    ```

独孤九剑/Java Learning

内容风险标识

评论 (0)

独孤九剑/Java Learning .gitee-modal { width: 500px !important; }

内容风险标识