线程池

Posted 2020-12-06 myitnews

一、简介

什么是线程池

线程池是一种多线程处理形式，处理过程中将任务添加到队列，然后在创建线程后自动启动这些任务。

为什么要用线程池

如果并发请求数量很多，但每个线程执行的时间很短，就会出现频繁的创建和销毁线程。如此一来，会大大降低系统的效率，可能频繁创建和销毁线程的时间、资源开销要大于实际工作的需要。

正是由于这个问题，所以有必要引入线程池。使用 线程池的好处 有以下几点：

• 降低资源消耗 - 通过重复利用已创建的线程降低线程创建和销毁造成的消耗。
• 提高响应速度 - 当任务到达时，任务可以不需要等到线程创建就能立即执行。
• 提高线程的可管理性 - 线程是稀缺资源，如果无限制的创建，不仅会消耗系统资源，还会降低系统的稳定性，使用线程池可以进行统一的分配，调优和监控。但是要做到合理的利用线程池，必须对其原理了如指掌。

二、Executor 框架

Executor 框架是一个根据一组执行策略调用，调度，执行和控制的异步任务的框架，目的是提供一种将”任务提交”与”任务如何运行”分离开来的机制。

核心API概述

Executor 框架核心 API 如下：

• Executor - 运行任务的简单接口。
• ExecutorService - 扩展了 Executor 接口。扩展能力：
  • 支持有返回值的线程；
  • 支持管理线程的生命周期。
• ScheduledExecutorService - 扩展了 ExecutorService 接口。扩展能力：支持定期执行任务。
• AbstractExecutorService - ExecutorService 接口的默认实现。
• ThreadPoolExecutor - Executor 框架最核心的类，它继承了 AbstractExecutorService 类。
• ScheduledThreadPoolExecutor - ScheduledExecutorService 接口的实现，一个可定时调度任务的线程池。
• Executors - 可以通过调用 Executors 的静态工厂方法来创建线程池并返回一个 ExecutorService 对象。

Executor

Executor 接口中只定义了一个 execute 方法，用于接收一个 Runnable 对象。

public interface Executor {
    void execute(Runnable command);
}

ExecutorService

ExecutorService 接口继承了 Executor 接口，它还提供了 invokeAll、invokeAny、shutdown、submit 等方法。

public interface ExecutorService extends Executor {

    void shutdown();

    List<Runnable> shutdownNow();

    boolean isShutdown();

    boolean isTerminated();

    boolean awaitTermination(long timeout, TimeUnit unit)
        throws InterruptedException;

    <T> Future<T> submit(Callable<T> task);

    <T> Future<T> submit(Runnable task, T result);

    Future<?> submit(Runnable task);

    <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks)
        throws InterruptedException;

    <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks,
                                  long timeout, TimeUnit unit)
        throws InterruptedException;

    <T> T invokeAny(Collection<? extends Callable<T>> tasks)
        throws InterruptedException, ExecutionException;

    <T> T invokeAny(Collection<? extends Callable<T>> tasks,
                    long timeout, TimeUnit unit)
        throws InterruptedException, ExecutionException, TimeoutException;
}

 

 

 

 

 

 

 

 

 

 

 

 

 

 

 

 

 

 

 

参考

https://www.cnblogs.com/jingmoxukong/p/12090064.html