p o l l 方 法 的 基 本 概 念 ( 2 0 2 0 ).pdfVIP

线程基础：线程池（5）——基本使用（上） 从本文开始，我将用两篇文章的篇幅，为各位读者呈现 JAVA 中原生的 线程池技术。第一篇文章，我将讲解 JAVA 原生线程池的基本使用，并由 此延伸出 JAVA 中和线程管理相关的类结构体系，然后我们详细描述 JAVA 原生线程池的结构和工作方式；第二篇文章，我们将继续深入，讲解 JAVA 原生线程池的高级特性，包括 Thread 工厂、队列、拒绝原则、钩子和相 关工具类。 如果您是【导师实战追-女课-程】JAVA 语言的初学者，请从本篇文章 看起；如果您对线程池技术已有一定的了解，那么可以只看下一篇文章； 如果您是【ＱＱ】高手，请绕行；如果您对我的观点有任何意见和建议， 请留言【⒈】，谢谢。^-^ 2、为【０】什么要使用线程池 前文我【１】们已经讲到，线程是一个操作系统概念。操作系统负责 这个线【６】程的创建、挂起、运行、阻塞和终结操作。而操作系统创建 线程、【⒐】切换线程状态、终结线程都要进行 CPU 调度——这是一个耗 费时间【５】和系统资-源的事情 （《操作系统知识回顾—进程线程模型》） 另一方面【２】，目前大多数生产环境我们所面临问题的技术背景一般 是：处理【б】某一次请求的时间是非常短暂的，但是请求数量是巨大的。 这种技术背景下，如果我们为每一个请求都单独创建一个线程，那么物理 机的所有资-源基本上都被操作系统创建线程、切换线程状态、销毁线程 这些操作所占用，用于业务请求处理的资 -源反而减少了。所以最理想的 处理方式是，将处理请求的线程数量控制在一个范围，既保证后续的请求 不会等待太长时间，又保证物理机将足够的资 -源用于请求处理本身。 另外，一些操作系统是有最大线程数量限制的。当运行的线程数量逼 近这个值的时候，操作系统会变得不稳定。这也是我们要限制线程数量的 原因。 3、线程池的基本使用方式 JAVA 语 言 为 我 们 提 供 了 两 种 基 础 线 程 池 的 选 择 ： ScheduledThreadPoolExecutor 和 ThreadPoolExecutor 。它们都实现了 ExecutorService 接口（注意，ExecutorService 接口本身和“线程池” 并没有直接关系，它的定义更接近“执行器”，而“使用线程管理的方式 进行实现”只是其中的一种实现方式） 。这篇文章中，我们主要围绕 ThreadPoolExecutor 类进行讲解。 3-1、简单使用 首先我们来看看ThreadPoolExecutor 类的最简单使用方式： package test.thread.pool; import java.util.concurrent.SynchronousQueue; import java.util.concurrent.ThreadPoolExecutor; import java.util.concurrent.TimeUnit; import mons.logging.Log; import mons.logging.LogFactory; import org.apache.log4j.BasicConfigurator; public class PoolThreadSimple { BasicConfigurator.configure(); public static void main(String[] args) throws Throwable { * corePoolSize ：核心大小，线程池初始化的时候，就会有这么大 * maximumPoolSize ：线程池最大线程数 * keepAliveTime ：如果当前线程池中线程数大于 corePoolSize 。 * 多余的线程，在等待keepAliveTime 时间后如果还没有新的线程任 务指派给它，它就会被回收 * unit ：等待时间keepAliveTime 的单位 * workQueue ：等待队列。这个对象的设置是本文将重点介绍的内容 ThreadPoolExecutor poolExecutor = new ThreadPoolExecutor(5, 10, 1, TimeUnit.MINUTES, new SynchronousQueueRunnable()); for(int inde