专栏首页JMCui多线程编程学习十(线程池原理).

多线程编程学习十(线程池原理).

一、线程池工作流程

  1. 线程池判断核心线程池里的线程是否都在执行任务。如果不是,则创建一个新的工作线程来执行任务(需要获得全局锁)。如果核心线程池里的线程都在执行任务,则进入下个流程。
  2. 线程池判断工作队列是否已满。如果工作队列没有满,则将新提交的任务存储在这个工作队列里。如果工作队列满了,则进入下个流程。
  3. 线程池判断线程池的线程是否都处于工作状态。如果没有,则创建一个新的工作线程来执行任务(需要获得全局锁)。如果已经满了,则交给饱和策略(例如抛出异常)来处理这个任务。

tips:这样的设计方案,可以避免频繁的线程创建,大部分的工作任务都会停留在第二步。

二、Executor 框架

在 Java 中,线程池的知识是要从 Executor 框架展开。Executor 框架主要由三部分组成:

1. 任务

包括 Runnable 接口或 Callable 接口。Runnable 接口无返回值,Callable 有返回值。

// Runnable 和 Callable 都可以直接被 ThreadPoolExecutor 和 ScheduledThreadPoolExecutor 执行
Runnable runnable = () -> System.out.println(123);
// Executors 可以将 Runnable 转化成 Callable
Callable<Object> callable = Executors.callable(runnable);
Callable<String> success = Executors.callable(runnable, "success");

2. 任务的执行

包括任务执行机制的核心接口 Executor、继承自 Executor 的 ExecutorService 接口以及实现 ExecutorService 的 ThreadPoolExecutor 和 ScheduledThreadPoolExecutor。

ThreadPoolExecutor 是线程池的核心实现类,用来执行被提交的任务。其中 ThreadPoolExecutor 的原理就是上面介绍的线程池工作流程。

ScheduledThreadPoolExecutor 继承自 ThreadPoolExecutor ,可以在给定的延迟后执行任务,或者定期执行任务。

Executors 是创建 ThreadPoolExecutor 和 ScheduledThreadPoolExecutor 的工厂类。

static ExecutorService executorService = Executors.newFixedThreadPool(5);

3. 异步计算的结果

包括 Future 接口以及实现 Future 的 FutureTask 类。

// 执行 Runnable
executorService.execute(runnable);
// 执行 Callable
Future<Object> submit = executorService.submit(callable);
// Future 的 get 方法会阻塞线程直到完成
System.out.println(submit.get());
Future<String> future = executorService.submit(success);
System.out.println(future.get());

Executor 线程池的使用大抵如下,首先,我们需要创建 Runnable 或者 Callable 任务。然后通过 ThreadPoolExecutor.execute() 或者 ThreadPoolExecutor.submit() 把任务交给 ThreadPoolExecutor 容器执行。由 submit 提交的任务会返回 Future,表示线程执行的结果,其中 Future 的 get 方法会阻塞线程直到完成。

Executor框架的使用示意图如下:

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

我来说两句

0 条评论
登录 后参与评论

相关文章

  • 多线程编程学习一(Java多线程的基础).

    一、进程和线程的概念 进程:一次程序的执行称为一个进程,每个 进程有独立的代码和数据空间,进程间切换的开销比较大,一个进程包含1—n个线程。进程是资源分享的最小...

    JMCui
  • 多线程编程学习三(线程间通信).

    一、概要 线程是操作系统中独立的个体,但这些个体如果不经过特殊的处理就不能成为一个整体,线程间的通信就是成为整体的必用方案之一。可以说,使线程进行通信后,系统...

    JMCui
  • HashMap、HashTable 和 ConcurrentHashMap 线程安全问题

    JDK 1.7 HashMap 采用数组 + 链表的数据结构,多线程背景下,在数组扩容的时候,存在 Entry 链死循环和数据丢失问题。

    JMCui
  • 实现线程的方式到底有几种?

    这篇文章主要讲解实现线程的方式到底有几种?以及实现 Runnable 接口究竟比继承 Thread 类实现线程好在哪里?

    武培轩
  • 如何创建线程池

    中强制线程池不允许使用 Executors 去创建,而是通过 ThreadPoolExecutor 的方式,这样的处理方式让写的同学更加明确线程池的运行规则,规...

    崔笑颜
  • 新手也能看懂的线程池学习总结

    线程池提供了一种限制和管理资源(包括执行一个任务)。每个线程池还维护一些基本统计信息,例如已完成任务的数量。

    乔戈里
  • (三)一个服务器程序的架构介绍

    本文将介绍我曾经做过的一个项目的服务器架构和服务器编程的一些重要细节。 一、程序运行环境 操作系统:centos 7.0 编译器:gcc/g++ 4.8.3 c...

    范蠡
  • 新手也能看懂的线程池学习总结

    线程池提供了一种限制和管理资源(包括执行一个任务)。每个线程池还维护一些基本统计信息,例如已完成任务的数量。

    Guide哥
  • 【Java后端面试经历】我和阿里面试官的“又”一次“邂逅”(附问题详解)

    承接上一篇深受好评的文章:《【Java 大厂真实面试经历】我和阿里面试官的一次“邂逅”(附问题详解)》 。时隔 n 个月,又一篇根据读者投稿的《5 面阿里,终获...

    Guide哥
  • [享学Netflix] 四十一、Ribbon核心API源码解析:ribbon-core(四)ClientException客户端异常

    代码下载地址:https://github.com/f641385712/netflix-learning

    YourBatman

扫码关注云+社区

领取腾讯云代金券