正文

Java多线程——<三>简单的线程执行：Executor

IP云
IP云V管理员/5 阅读
08/04
提示：扫一扫查出行
【扫一扫了解最新限行尾号】
复制提示

一、概述

按照《Java多线程——<一><二>》中所讲，我们要使用线程，目前都是显示的声明Thread，并调用其start()方法。多线程并行，明显我们需要声明多个线程然后都调用他的start方法，这么一看，似乎有些问题：第一、线程一旦多了，声明势必是个问题；第二、多线程启动如果通过手动执行的话，那可能一个线程已经跑完了，另外一个还没起来（我推测可能会出现这个问题）。所以，我们在想，如果有个管家，能够帮我们管理这么多线程，只需要把我们定义的任务交给管家，管家就能够帮我们把任务附着到线程上，并且当我们给管家发送指令让所有的线程开始并发执行时，他也能够帮助我们开启所有线程执行。

二、java多线程管家——Executor

Executor允许你管理异步任务的执行，而无须显示地管理线程的生命周期。ExecutorService知道如何构建恰当的上下文来执行Runnable对象。
1.创建ExecutorService

通过Executors能够创建两种方式的ExectorService。第一种、CachedThreadPool会为每个传入的任务新创建一个线程

ExecutorService exec = Executors.newCachedThreadPool();

第二种、FixedThreadPool可以一次性预先执行代价高昂的线程分配，所以可以用来限制线程的数量。这可以节省时间，因为你不必为每个任务都固定的付出创建线程的开销。

ExecutorService exeService = Executors.newFixedThreadPool(5);

2.把任务附着给ExecutorService

有了executor，你只需要定义任务并将任务对象传递给executor即可。

exeService.execute(new Task());

3.让所有任务开始执行

这两个方法会让之前提交到该exectuor的所有任务开始执行。为了避免启动后，会被注入新的任务，必须在你将所有线程注入后，执行关闭操作以保证这一点。

exeService.shutdown();

总结：

|——原来：想执行任务
| | |——1.定义任务
| | |——2.创建任务对象交由Thread对象操纵
| | |——3.显示的调用Thread对象的start()方法
| |——遇到问题：比较繁琐，总得自己启动线程调用；本质上是由main函数调用的
|——现在：使用java.util.concurrent.Executor（执行器）来管理Thread对象
| | |——1.ExecutorService exec = Executors.newAcahedThreadPool();
| | |——2.exec.execute(new Task());
| | |——3.exec.shutdown();
| |——在客户端（显示调用线程执行）和执行任务之间提供了一个间接层，用以执行任务；撇开了main函数，由executor直接进行了调用
| |——允许你管理异步任务的执行，而无须显示地管理线程的生命周期

三、其他

1.何时使用哪种线程池呢？
CachedThreadPool在程序执行过程中通常会创建与所需数量相同的线程，然后在它回收旧线程时停止创建新线程，因此它是合理的Executor的首选
只有当这种方式会引起问题时，才需要切换到FixedThreadPool。

2.SingleThreadExecutor

SingleThreadExecutor就像是线程数量为1的FixedThreadPool
|——在另一个线程中连续运行的任何事务来说都很有用（重点是连续运行，因为这样可以顺序接受处理），故SingleThreadPool会序列化所有提交给它的任务， 并会维护它自己隐藏的悬挂任务队列
|——例如：向SingleThreadExecutor提交多个任务，那么这些任务将排队，每个任务都会在下一个任务开始之前运行结束，所有任务使用相同线程。

3.自定义线程工厂

每个静态的ExecutorService创建方法都被重载为接受一个ThreadFactory对象，该对象将被用来创建新的线程。例如：

public class TaskDaemonFactory implements ThreadFactory{
public Thread newThread(Runnable r){
Thread t = new Thread(r);return t;
}
}

想使用自己定义的线程工厂

ExecutorService exec = Executors.newCachedThreadPool(new TaskDaemonFactory());

这样可以通过具体的要求来改造线程。

注：以上代码均来自《Thinking in java》，内容均来自个人理解与总结，如有理解错误，请大家批评指正

Java多线程——<三>简单的线程执行：Executor的更多相关文章

  1. Java多线程系列四——控制线程执行顺序

    假设有线程1/线程2/线程3,线程3必须在线程1/线程2执行完成之后开始执行,有两种方式可实现 Thread类的join方法:使宿主线程阻塞指定时间或者直到寄生线程执行完毕 CountDownLatc ...

  2. Java多线程之简单的线程同步实例

    数据类: package Thread.MyCommon; public class Data { public int num = 0; public synchronized int getEve ...

  3. Java 多线程&lpar;三）之线程状态及其验证

    目录 线程状态 Thread.State 状态类型 定义 说明 状态转换 状态验证 「NEW」-> 「RUNNABLE」 -> 「TERMINATED」 「RUNNABLE」 -> ...

  4. Java多线程（二） —— 线程安全、线程同步、线程间通信（含面试题集）

    一.线程安全 多个线程在执行同一段代码的时候,每次的执行结果和单线程执行的结果都是一样的,不存在执行结果的二义性,就可以称作是线程安全的. 讲到线程安全问题,其实是指多线程环境下对共享资源的访问可能会 ...

  5. Java多线程（一） —— 线程的状态详解

    一.多线程概述  1. 进程 是一个正在执行的程序.是程序在计算机上的一次运行活动. 每一个进程执行都有一个执行顺序.该顺序是一个执行路径,或者叫一个控制单元. 系统以进程为基本单位进行系统资源的调度 ...

  6. Java多线程（五）线程的生命周期

    点我跳过黑哥的卑鄙广告行为,进入正文. Java多线程系列更新中~ 正式篇: Java多线程(一) 什么是线程 Java多线程(二)关于多线程的CPU密集型和IO密集型这件事 Java多线程(三)如何 ...

  7. &OpenCurlyDoubleQuote;全栈2019”Java多线程第八章：放弃执行权yield&lpar;&rpar;方法详解

    难度 初级 学习时间 10分钟 适合人群 零基础 开发语言 Java 开发环境 JDK v11 IntelliJ IDEA v2018.3 文章原文链接 "全栈2019"Java多 ...

  8. Java多线程-同步&colon;synchronized 和线程通信&colon;生产者消费者模式

    大家伙周末愉快,小乐又来给大家献上技术大餐.上次是说到了Java多线程的创建和状态|乐字节,接下来,我们再来接着说Java多线程-同步:synchronized 和线程通信:生产者消费者模式. 一.同 ...

  9. java 多线程三

    java 多线程一 java 多线程二 java 多线程三 java 多线程四 注意到 java 多线程一 中 MyThread2 运行结果出现0.-1,那是因为在操作共享数据时没有加锁导致. 加锁的 ...

随机推荐

  1. Eclipse web项目引用其它项目时的部署问题

    地址:http://blog.csdn.net/testcs_dn/article/details/43764497

  2. SQL Server 2012 自动增长列，值跳跃问题

    介绍 从 SQL Server 2012 版本开始, 当SQL Server 实例重启之后,表格的自动增长列的值会发生跳跃,而具体的跳跃值的大小是根据增长列的数据类型而定的.如果数据类型是 整型(in ...

  3. HttpURLConnection下载图片的两种方式

    public class MainActivity extends AppCompatActivity { private ImageView iv; private String imageurl ...

  4. Mysql的ssl主从复制&plus;半同步主从复制

    Mysql的ssl主从复制+半同步主从复制 准备工作 1.主从服务器时间同步 [root@localhost ~]# crontab -e */30 * * * * /usr/sbin/ntpdate ...

  5. 一位学长的ACM总结（感触颇深）

    发信人: fennec (fennec), 信区: Algorithm 标 题: acm 总结 by fennec 发信站: 吉林大学牡丹园站 (Wed Dec 8 16:27:55 2004) AC ...

  6. jwplayer 禁止视频的快进，但是可以后退（已实现）

    一直在研究.net 的视频播放,最近做起了jwplayer,然后项目要求是视频不能快进,但是可以重复观看已经看过的视频资源. 很简单 在标签<script> 中定义两个变量 var max ...

  7. 【转载】Perl中的引用

    为什么使用引用? 在perl4中,hash表中的value字段只能是scalar,而不能是list,这对于有些情况是很不方便的,比如有下面的数据: Chicago, USAFrankfurt, Ger ...

  8. Linux服务器，服务管理--systemctl命令详解，设置开机自启动

    Linux服务器,服务管理--systemctl命令详解,设置开机自启动 syetemclt就是service和chkconfig这两个命令的整合,在CentOS 7就开始被使用了. 摘要: syst ...

  9. python note 15 正则表达式

    # 正则表达式 只和字符串打交道 # 正则表达式的规则# 规则 字符串 从字符串中找到符合规则的内容 # 字符组 : [] 写在中括号中的内容,都出现在下面的某一个字符的位置上都是符合规则的 # [0 ...

  10. SpringCloud 启动时报No active profile set&comma; falling back to default profiles default

    这在Spring程序启动时没有找到默认的配置文件所引发的错误,默认文件application.yml如下图:  一般在项目中都会有多个,如有正式环境.测试环境等.如下图: 根据上面这种多个配置的只需要 ...