线程创建的三种方式和线程池创建的四种方式
线程创建的三种方式和线程池创建的四种方式
1.1线程创建的方式
java创建线程的三种方式:
- 继承Thread类创建线程类
- 实现Runnable接口
- 通过Callable和Future创建线程
1.2创建线程
1.2.1继承Thread类
(1)创建Thread类的子类,并重写该类的run方法,该run方法的方法体就代表了线程要完成的任务。因此把run()方法称为执行体。
(2)创建了Thread子类的实例,即创建了线程对象。
(3)调用线程对象的start()方法来启动该线程。
package com.thread;public class Thread01 {public static void main(String[] args) {MyThread01 t1=new MyThread01();MyThread01 t2=new MyThread01();t1.start();t2.start();}
}class MyThread01 extends Thread{@Overridepublic void run() {System.out.println("线程名:"+currentThread().getName());}
}
1.2.2实现Runnable接口
(1)定义runnable接口的实现类,并重写该接口的run()方法,该run()方法的方法体同样是该线程的线程执行体。
(2)创建 Runnable实现类的实例,并依此实例作为Thread的target来创建Thread对象,该Thread对象才是真正的线程对象。
(3)调用线程对象的start()方法来启动该线程。
线程的执行流程很简单,当执行代码start()时,就会执行对象中重写的void run()方法,该方法执行完成后,线程就消亡了。
package com.thread;public class Thread02 {public static void main(String[] args) {MyThread02 target=new MyThread02();Thread t1=new Thread(target);Thread t2=new Thread(target);t1.start();t2.start();}
}class MyThread02 implements Runnable{@Overridepublic void run() {System.out.println("线程名:"+Thread.currentThread().getName());}
}
1.2.3实现Callable接口
(1)创建Callable接口的实现类,并实现call()方法,该call()方法将作为线程执行体,并且有返回值。
(2)创建Callable实现类的实例,使用FutureTask类来包装Callable对象,该FutureTask对象封装了该Callable对象的call()方法的返回值。
(3)使用FutureTask对象作为Thread对象的target创建并启动新线程。
(4)调用FutureTask对象的get()方法来获得子线程执行结束后的返回值
package com.thread;import java.util.concurrent.*;public class Thread03 {public static void main(String[] args) throws ExecutionException, InterruptedException, TimeoutException {Callable callable=new MyThread03();FutureTask task1=new FutureTask(callable);FutureTask task2=new FutureTask(callable);new Thread(task1).start();new Thread(task2).start();Thread.sleep(10);//等待线程执行结束//task.get() 获取call()的返回值。若调用时call()方法未返回,则阻塞线程等待返回值System.out.println(task1.get());System.out.println(task2.get());//get的传入参数为等待时间,超时抛出超时异常;传入参数为空时,则不设超时,一直等待System.out.println(task1.get(10L, TimeUnit.MILLISECONDS));System.out.println(task2.get(10L, TimeUnit.MILLISECONDS));}
}class MyThread03 implements Callable{@Overridepublic Object call() throws Exception {System.out.println("线程名:"+Thread.currentThread().getName());return "实现callable:"+Thread.currentThread().getName();}
}
1.2.4三种方式的对比
采用继承Thread类方式:
(1)优点:编写简单,如果需要访问当前线程,无需使用Thread.currentThread()方法,直接使用this,即可获得当前线程。
(2)缺点:因为线程类已经继承了Thread类,所以不能再继承其他的父类。
采用实现Runnable接口方式:
(1)优点:线程类只是实现了Runable接口,还可以继承其他的类。在这种方式下,可以多个线程共享同一个目标对象,所以非常适合多个相同线程来处理同一份资源的情况,从而可以将CPU代码和数据分开,形成清晰的模型,较好地体现了面向对象的思想。
(2)缺点:编程稍微复杂,如果需要访问当前线程,必须使用Thread.currentThread()方法。
Runnable和Callable的区别:
(1)Callable规定的方法是call(),Runnable规定的方法是run().
(2)Callable的任务执行后可返回值,而Runnable的任务是不能返回值得
(3)call方法可以抛出异常,run方法不可以,因为run方法本身没有抛出异常,所以自定义的线程类在重写run的时候也无法抛出异常
(4)运行Callable任务可以拿到一个Future对象,表示异步计算的结果。它提供了检查计算是否完成的方法,以等待计算的完成,并检索计算的结果。通过Future对象可以了解任务执行情况,可取消任务的执行,还可获取执行结果。
1.2.5start()和run()的区别
start()方法用来,开启线程,但是线程开启后并没有立即执行,他需要获取cpu的执行权才可以执行
run()方法是由jvm创建完本地操作系统级线程后回调的方法,不可以手动调用(否则就是普通方法)
2.创建线程池的四种方式
(1)newCachedThreadPool 创建一个可缓存的线程池,如果线程池长度超过处理需求,可灵活回收空闲线程,若无可回收,则新建线程。
(2)newFixedThreadPool 创建一个定长线程池,可控制线程最大并发数,超出的线程会在队列中等待
(3)newScheduledThreadPool 创建一个定长线程池,支持定时及周期性任务执行
(4)newSingleThreadExecutor 创建一个单线程化的线程池,它只会唯一的工作线程来执行任务,保证所有任务按照指定顺序(FIFO,LIFO,优先级)执行
线程池的优点:
(1)重用存在的线程,减少对象创建、消亡的开销,性能佳。
(2)可有效控制最大并发线程数,提高系统资源的使用率,同时避免过多资源竞争,避免堵塞。
(3)提供定时执行、定期执行、单线程、并发数控制等功能。
使用newThread的弊端
- 每次new Thread新建对象性能差。
- 线程缺乏统一管理,可能无限制新建线程,相互之间竞争,及可能占用过多系统资源导致死机或oom(out of memory)。
- 缺乏更多功能,如定时执行、定期执行、线程中断。
2.1使用newCachedThreadPool
创建一个可缓存线程池,如果线程池长度超过处理需要,可灵活回收空闲线程,若无可回收,则新建线程。
package com.thread;import sun.rmi.runtime.Log;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;public class ThreadPoolDemo01 {public static void main(String[] args) {ExecutorService cachedThreadPool= Executors.newCachedThreadPool();for(int i=0;i<20;i++){final int index=i;try {Thread.sleep(index*100);} catch (InterruptedException e) {e.printStackTrace();}cachedThreadPool.execute(new Runnable() {@Overridepublic void run() {System.out.println("此线程名:"+Thread.currentThread().getName());}});}}
}
线程池为无限大,当执行第二个任务时第一个任务已经完成,会复用执行第一个任务的线程,而不用每次新建线程。
2.2 newFixedThreadPool
需要指定线程池的大小,创建一个定长线程池,可控制线程最大并发数,超出的线程会在队列中等待。
package com.thread;import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;public class ThreadPoolDemo02 {public static void main(String[] args) {ExecutorService fixedThreadPool= Executors.newFixedThreadPool(3);for(int i=0;i<10;i++){final int index=i;fixedThreadPool.execute(new Runnable() {@Overridepublic void run() {try {Thread.sleep(2000);} catch (InterruptedException e) {e.printStackTrace();}System.out.println("线程名:"+Thread.currentThread().getName());}});}}
}
因为线程池大小为3,每个任务输出index后sleep 2秒,所以每两秒打印3个数字。定长线程池的大小最好根据系统资源进行设置。
2.3newScheduledThreadPool
创建一个定长线程池,支持定时及周期性任务执行。延迟执行示例代码如下:
延迟3秒执行
package com.thread;import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;public class ThreadPoolDemo03 {public static void main(String[] args) {ScheduledExecutorService scheduledThreadPool= Executors.newScheduledThreadPool(5);scheduledThreadPool.schedule(new Runnable() {@Overridepublic void run() {System.out.println("线程名:"+Thread.currentThread().getName());}},3, TimeUnit.SECONDS);}
}
定期执行:
表示延迟1秒后每3秒执行一次。
ScheduledExecutorService比Timer更安全,功能更强大
package com.thread;import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;public class ThreadPoolDemo03_2 {public static void main(String[] args) {ScheduledExecutorService scheduledThreadPool= Executors.newScheduledThreadPool(5);scheduledThreadPool.scheduleAtFixedRate(new Runnable() {@Overridepublic void run() {System.out.println("线程名:"+Thread.currentThread().getName());}},1,3, TimeUnit.SECONDS);}
}
2.4newSingleThreadExecutor
创建一个单线程化的线程池,它只会用唯一的工作线程来执行任务,保证所有任务按照指定顺序(FIFO, LIFO, 优先级)执行。示例代码如下:
package com.thread;import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;public class ThreadPoolDemo04 {public static void main(String[] args) {ExecutorService singleThreadExecutor= Executors.newSingleThreadExecutor();for(int i=0;i<10;i++){singleThreadExecutor.execute(new Runnable() {@Overridepublic void run() {try {Thread.sleep(2000);} catch (InterruptedException e) {e.printStackTrace();}System.out.println("线程名:"+Thread.currentThread().getName());}});}}
}
结果依次输出,相当于顺序执行各个任务。
线程池的作用:
线程池作用就是限制系统中执行线程的数量。
根据系统的环境情况,可以自动或手动设置线程数量,达到运行的最佳效果;少了浪费了系统资源,多了造成系统拥挤效率不高。用线程池控制线程数量,其他线程排队等候。一个任务执行完毕,再从队列的中取最前面的任务开始执行。若队列中没有等待进程,线程池的这一资源处于等待。当一个新任务需要运行时,如果线程池中有等待的工作线程,就可以开始运行了;否则进入等待队列。
为什么要用线程池:
1.减少了创建和销毁线程的次数,每个工作线程都可以被重复利用,可执行多个任务。
2.可以根据系统的承受能力,调整线程池中工作线线程的数目,防止因为消耗过多的内存,而把服务器累趴下(每个线程需要大约1MB内存,线程开的越多,消耗的内存也就越大,最后死机)。
Java里面线程池的顶级接口是Executor,但是严格意义上讲Executor并不是一个线程池,而只是一个执行线程的工具。真正的线程池接口是ExecutorService。
比较重要的几个类:
ExecutorService: 真正的线程池接口。
ScheduledExecutorService: 能和Timer/TimerTask类似,解决那些需要任务重复执行的问题。
ThreadPoolExecutor: ExecutorService的默认实现。
ScheduledThreadPoolExecutor: 继承ThreadPoolExecutor的ScheduledExecutorService接口实现,周期性任务调度的类实现。
要配置一个线程池是比较复杂的,尤其是对于线程池的原理不是很清楚的情况下,很有可能配置的线程池不是较优的,因此在Executors类里面提供了一些静态工厂,生成一些常用的线程池。
线程创建的三种方式和线程池创建的四种方式相关推荐
- golang: 密码中允许出现数字、大写字母、小写字母、特殊字符,但至少包含其中2种且长度在8-16之间(四种符号任意满足三种即可)
要求: 密码中允许出现数字.大写字母.小写字母.特殊字符(.@$!%*#_~?&^),但至少包含其中2种且长度在8-16之间(四种符号任意满足三种即可) package mainimport ...
- Java 线程池原理及四种常用的线程池使用
推荐阅读:Java线程池实现原理及其在美团业务中的实践 文章目录 什么是线程池 使用线程池的好处 线程池的实现原理 流程图分析 源码分析 线程池的使用 向线程池中提交任务 newCachedThrea ...
- php格式图片怎么打开方式,php格式文件打开的四种方法
php文件格式怎么打开?要搞清楚php文件用什么打开,首先我们来看php文件是什么文件,PHP是一个网页脚本,文件后缀名为.php,如下图: 但不同于html xml 标签语言,直接可以通过浏览器打开 ...
- 计算机系统的四种启动方式是,U盘启动有四种模式?云骑士装机大师教你怎么选...
原标题:U盘启动有四种模式?云骑士装机大师教你怎么选 在下载云骑士装机的U盘启动盘时,我们可以看到有4种启动方式,HDD-FAT32.ZIP-FAT32.HDD-FAT16.ZIP-FAT32,有些用 ...
- java的四种引用类型_你知道Java的四种引用类型吗?
以下文章来源于程序员柯南 ,作者薛勤 点击蓝字关注我们 点击上方"方志朋",选择"置顶或者星标" 你的关注意义重大!01概述 在Java中提供了四个级别的引用: ...
- 计算机退出程序的四种方法,退出windows10系统账户的四种方法
网友反馈说Win10系统打开某些程序时,经常会弹出提示"你要允许以下程序对此计算机进行更改吗?"每回都要手动关闭,而且频繁的弹出影响办公效率,有什么办法能将此窗口给永久关闭?退出微 ...
- 四种形态图解_涨停板战法的四种形态(图解)
在平常的操作中,短线操作是大多数投资者都会使用的方法,涨停板战法同样是短线操作的一种非常受欢迎方法之一.因为涨停板是把股价上涨发挥到极致,但是操作涨停板也并不是很容易的,必须有判断涨停的能力以及后市的 ...
- 快速排序 python 4种写法_[算法] 关于快速排序的四种写法
前序 说到排序算法,应该算是家喻户晓,人人皆知的大路货了.但是往往这些为人所熟知的东西中,也存在一些可以令人琢磨的细节. 这不,某天深夜,无所事事,大概是太寂寞,在思念了一番妹子以后,脑子里突然闪过了 ...
- java 四种内存_不可访问内存 Java四种引用包括强引用,软引用,弱引用,虚引用...
小结: 1.不可访问内存是指一组没有任何可访问指针指向的由计算机程序进行动态分配的内存块. 2.垃圾收集器能决定是否一个对象还是可访问的:任何被确定不可访问的对象将会被释放. https://zh.w ...
- python接口自动化(三十二)--Python发送邮件(常见四种邮件内容)番外篇——上(详解)...
简介 本篇文章与前边没有多大关联,就是对前边有关发邮件的总结和梳理.在写脚本时,放到后台运行,想知道执行情况,会通过邮件.SMS(短信).飞信.微信等方式通知管理员,用的最多的是邮件.在linux下, ...
最新文章
- mysql+性能优化+命令_MySQL性能优化
- 红黑树的删除_Python实现红黑树的删除操作
- 详细到没朋友,一文帮你理清Linux 用户与用户组关系~
- JMM模型到并发编程
- pythonunicode和str_Python中的str与unicode处理方法
- 算法:找出存在子字符串的最先位置28. Implement strStr()
- 循序渐进 OSPF的详细剖析(二)
- 使用计算机制图的心得,学习cad制图心得体会
- 图信号处理之图拉普拉斯矩阵的含义
- C++用户的Cplex使用指南(三)——Cutting stock problem求解
- MyBatis之one2one与one2many
- [ 加拿大访问学者 ] 用于签证的访问学者研究计划 [ 提交大使馆 签证用 ]
- 24 个必须掌握的数据库⾯试题
- Linux安装iso镜像中的软件
- echarts 水滴图 去掉波浪阴影
- Android平台App进程优先级
- 计算机打开程序乱码,打开软件乱码怎么解决,详解win7电脑打开软件乱码的解决方法...
- KCL:蚂蚁自研的配置策略语言
- Android自定义控件增加xml标签属性、取值等
- xv6源码阅读——中断与异常
热门文章
- flash builder4.6 集成svn1.8报错
- 开源电路仿真软件CircuitJS1介绍与使用入门
- mysql数据库实验报告模板_MySQL数据库技术》实验报告模板.doc
- 超级浏览器究竟是什么?
- VBA入门--VBA基础知识和简单技能技巧
- access vba代码大全_VBA编程在翻译中的应用
- 自己做量化交易软件(45)小白量化实战18--直接使用通达信自编指标公式进行分析绘图和回测
- 大数据抗疫的“洪荒之力”:多地政府借力大数据技术,多家企业上马大数据产品...
- 佳顺通用进销存系统去广告_免费在线进销存软件弊端之重复投资
- 注册表--设置文件打开方式