你好,我是码哥,可以叫我靓仔。
线程池是一种用于管理和重用线程的机制,它允许开发人员有效地执行并发任务。通过使用线程池,可以带来了许多好处:
接下来以 Java 中的线程池实现机制为例,带你掌握线程池的工作机制。
线程池的工作机制可以看作是一种生产者-消费者模型的应用。
在这个模型中,任务(生产者)被提交到线程池,然后线程池中的线程(消费者)从任务队列中取出任务并执行,线程池模型架构如下图:
线程池的执行流程图如下所示。
Java 中的线程池具有不同的状态,这些状态反映了线程池在其生命周期中的不同阶段和行为。主要的线程池状态有以下几种:
状态 | 描述 |
---|---|
RUNNING(运行中) | 表示线程池正在正常运行,并且可以接受新的任务提交。在这种状态下,线程池可以执行任务,并且可以创建新的线程来处理任务。 |
SHUTDOWN(关闭中) | 表示线程池正在关闭中。在这种状态下,线程池不再接受新的任务提交,但会继续执行已提交的任务,直到所有任务执行完成。 |
STOP(停止) | 表示线程池已经停止,不再接受新的任务提交,并且尝试中断正在执行的任务。 |
TERMINATED(终止) | 表示线程池已经终止,不再接受新的任务提交,并且所有任务已经执行完成。在这种状态下,线程池中的所有线程都已经被销毁。 |
这些状态是通过 ThreadPoolExecutor 类中的 ctl(control)字段来维护的,ctl
是一个 AtomicInteger 类型的变量,它的高 3 位表示线程池的运行状态,低 29 位表示线程池中的工作线程数量。
在 ThreadPoolExecutor 中,通过位运算来修改和检查 ctl 的值,以实现线程池状态的转换和管理。
通过 ctl 字段,ThreadPoolExecutor 类能够高效地维护线程池的状态和线程数量信息,从而实现了对线程池的有效管理和控制。
要注意的是,线程池的状态不是直接设置的,而是通过调用 shutdown()、shutdownNow() 等方法触发状态的转换。
例如,调用 shutdown() 方法会将线程池的状态从 RUNNING 转换为 SHUTDOWN。
线程池的拒绝策略用于定义当线程池已满并且无法处理新提交的任务时应该采取的行动。以下是 Java 中常见的线程池拒绝策略:
策略名称 | 描述 |
---|---|
AbortPolicy(默认策略) | 如果线程池已满并且无法接受新任务,则会抛出 RejectedExecutionException 异常。这是默认的拒绝策略。 |
CallerRunsPolicy | 当线程池已满时,会使用提交任务的线程来执行该任务。换句话说,如果无法接受新任务,则会由提交任务的线程自己执行该任务。 |
DiscardPolicy | 当线程池已满时,会丢弃掉无法处理的新任务,而不会抛出异常。 |
DiscardOldestPolicy | 当线程池已满时,会丢弃队列中等待时间最长的任务,然后尝试将新任务加入队列。 |
除了上述标准拒绝策略之外,您还可以实现 RejectedExecutionHandler 接口来定义自定义的拒绝策略。这使您能够根据应用程序的需求实现更复杂的拒绝逻辑。RejectedExecutionHandler 接口:
public interface RejectedExecutionHandler {
void rejectedExecution(Runnable r, ThreadPoolExecutor executor);
}
提交任务给线程池触发线程池的拒绝策略如下图所示。
Java 线程池在业务中有许多实践应用,以下是其中一些常见的实践方式:
连接池是一组预先初始化和可重复使用的数据库连接。它用于管理到数据库的连接池,允许多个客户端共享和重复使用数据库连接。
连接池有助于通过减少建立和关闭数据库连接的开销来提高数据库密集型应用程序的性能和可伸缩性。
线程池和连接池都是用于提高系统性能和资源利用率的重要技术,但它们的主要区别在于应用场景和管理的资源类型。
线程池用于管理可重复使用的线程资源,以便有效地执行并发任务,而连接池则用于管理可重复使用的数据库连接资源,以便高效地处理数据库访问。
如下图是数据库连接池工作机制。
博主简介
码哥,9 年互联网公司后端工作经验,后端架构师,InfoQ 签约作者、51CTO Top 红人,阿里云开发者社区专家博主,擅长 Redis、Spring、Kafka、MySQL 技术,在云原生微服务领域有着深入研究。