Java多线程(案例+解析)JDK5.0新增的线程的创建方式
1、●JDK 5.0起提供了线程池相关API:
2、●
3、●
发布日期:2021-06-29 15:03:05
浏览次数:2
分类:技术文章
本文共 5259 字,大约阅读时间需要 17 分钟。
新增方式一:实现Callable接口
●与使用Runnable相比,Callable功能更强大些
➢相比run()方法, 可以有返回值。
➢方法可以抛出异常。 ➢支持泛型的返回值。 ➢需要借助FutureTask类, 比如获取返回结果。1、创建NumThread实现Callable接口的方式创建线程
package com.itzheng.java2;/*创建线程的方式三:实现Callable接口。---JDK 5.0新增 */import java.util.concurrent.Callable;import java.util.concurrent.ExecutionException;import java.util.concurrent.FutureTask;/*1、创建一个实现Callable的实现类 */class NumThread implements Callable{ //2、实现call方法,将此线程需要执行的操作声明在call()方法当中 @Override public Object call() throws Exception { int sum = 0; for (int i = 1; i <= 100 ; i++) { if(i%2 == 0){ System.out.println(i); sum += i; } } return sum; }}public class ThreadNew { public static void main(String[] args) { // 3、创建Callable接口实现的对象 NumThread numThread = new NumThread(); // 4、将此Callable接口实现的对象作为参数传递到FutureTask构造器当中,创建FutureTask的对象 FutureTask futureTask = new FutureTask(numThread); //5、将FutureTask的对象作为参数传递到Thread类当中构造器中,创建Thread对象,并调用start()方法 new Thread(futureTask).start(); try { //6、获取Callable中的call方法的返回值 //get()方法的返回值即为FutureTask构造器参数Callable实现类重写的call()方法的返回值。 Object sum = futureTask.get(); System.out.println("总和为:"+sum); } catch (InterruptedException e) { e.printStackTrace(); } catch (ExecutionException e) { e.printStackTrace(); } }}
2、如何理解:实现Callable接口的方式创建多线程比实现Runnable接口创建多线程方式强大?
1、call()可以有返回值的
2、call()是可以抛出异常,被外面的操作捕获,获取异常的信息 3、Callable()是支持泛型的package com.itzheng.java2;/*创建线程的方式三:实现Callable接口。---JDK 5.0新增如何理解:实现Callable接口的方式创建多线程比实现Runnable接口创建多线程方式强大?1、call()可以有返回值的2、call()是可以抛出异常,被外面的操作捕获,获取异常的信息3、Callable()是支持泛型的 */import java.util.concurrent.Callable;import java.util.concurrent.ExecutionException;import java.util.concurrent.FutureTask;/*1、创建一个实现Callable的实现类 */class NumThread implements Callable{ //2、实现call方法,将此线程需要执行的操作声明在call()方法当中 @Override public Integer call() throws Exception { int sum = 0; for (int i = 1; i <= 100 ; i++) { if(i%2 == 0){ System.out.println(i); sum += i; } } return sum; }}public class ThreadNew { public static void main(String[] args) { // 3、创建Callable接口实现的对象 NumThread numThread = new NumThread(); // 4、将此Callable接口实现的对象作为参数传递到FutureTask构造器当中,创建FutureTask的对象 FutureTask futureTask = new FutureTask (numThread); //5、将FutureTask的对象作为参数传递到Thread类当中构造器中,创建Thread对象,并调用start()方法 new Thread(futureTask).start(); try { //6、获取Callable中的call方法的返回值 //get()方法的返回值即为FutureTask构造器参数Callable实现类重写的call()方法的返回值。 Integer sum = futureTask.get(); System.out.println("总和为:"+sum); } catch (InterruptedException e) { e.printStackTrace(); } catch (ExecutionException e) { e.printStackTrace(); } }}
新增方式二:使用线程池。
●1、背景:
经常创建和销毁、使用量特别大的资源,比如并发情况下的线程,
对性能影响很大。● 2、思路:
提前创建好多个线程,放入线程池中,使用时直接获取,使用完
放回池中。可以避免频繁创建销毁、实现重复利用。类似生活中的公共交 通工具。● 3、好处:
➢提高响应速度(减少了创建新线程的时间)
➢降低资源消耗(重复利用线程池中线程,不需要每次都创建) ➢便于线程管理 corePoolSize: 核心池的大小 maximumPoolSize: 最大线程数 keepAliveTime:线程没有任务时最多保持多长时间后会终止一、线程池相关API
1、●JDK 5.0起提供了线程池相关API: ExecutorService和Executors
2、●ExecutorService
: 真正的线程池接口。常见子类ThreadPoolExecutor
➢void execute(Runnable command):
执行任务/命令,没有返回值,-般用来执行
<T> Future<T> submit(Callable<T> task):
执行任务,有返回值,-般又来执行 Callable ➢void shutdown():
关闭连接池 3、●Executors
: 工具类、线程池的工厂类,用于创建并返回不同类型的线程池
➢Executors newCachedThreadPool():
创建一个可 根据需要创建新线程的线程池
Executors.newFixedThreadPool(n);
创建一个可 重用固定线程数的线程池 ➢Executors.newSingle ThreadExecutor():
创建一个 只有一个线程的线程池 ➢Executors.newScheduledThreadPool(n):
创建-个线程池,它可安排在给定延迟后运行命令或者定期地执行。 二、相应的代码实现
package com.itzheng.java2;import java.util.concurrent.ExecutorService;import java.util.concurrent.Executors;import java.util.concurrent.ThreadPoolExecutor;/*创建线程的方式四:使用线程池 */class NumberThread implements Runnable{ @Override public void run() { for(int i = 0; i <= 100; i++){ if(i % 2 == 0){ System.out.println(Thread.currentThread().getName() +":"+ i); } } }}class NumberThread1 implements Runnable{ @Override public void run() { for(int i = 0; i <= 100; i++){ if(i % 2 != 0){ System.out.println(Thread.currentThread().getName() +":"+ i); } } }}public class ThreadPool { public static void main(String[] args) { //1、提供指定线程数量的连接池 ExecutorService service = Executors.newFixedThreadPool(10); ThreadPoolExecutor service1 = (ThreadPoolExecutor)service; //设置线程池的一些属性 System.out.println(service.getClass());// service1.setCorePoolSize(15);// service1.setKeepAliveTime(); //2、执行指定的线程的操作。需要提供一个实现Runnable接口或者是 Callable接口实现类的对象 service.execute(new NumberThread());//适合适用于Runnable service.execute(new NumberThread1());//适合适用于Runnable //service.submit(new Callable()); 适合使用于Callable //3、关闭连接池 service.shutdown(); }}
转载地址:https://code100.blog.csdn.net/article/details/110917957 如侵犯您的版权,请留言回复原文章的地址,我们会给您删除此文章,给您带来不便请您谅解!
发表评论
最新留言
哈哈,博客排版真的漂亮呢~
[***.90.31.176]2024年04月08日 23时26分09秒
关于作者
喝酒易醉,品茶养心,人生如梦,品茶悟道,何以解忧?唯有杜康!
-- 愿君每日到此一游!
推荐文章
自制一个害羞的口罩,见人就闭嘴,戴着可以喝奶茶
2019-04-29
聊聊我是如何编程入门的
2019-04-29
J-Link该如何升级固件?
2019-04-29
485通信自动收发电路,历史上最详细的解释
2019-04-29
【视觉盛宴三】不好意思,这些线材接口的横截面真的没见过
2019-04-29
一位头发发白的神人教你怎么写程序,运维,买电脑,写文章,平面设计!
2019-04-29
【第二期】那些设计漂亮、有创意的电路板!
2019-04-29
【第三期】那些设计漂亮、有创意的电路板!
2019-04-29
继续推荐公众号~
2019-04-29
「第二篇」全国一等奖,经验帖。
2019-04-29
「第三篇」全国电子设计竞赛,这些你必须知道的比赛细节,文末附上近十年电赛题目下载...
2019-04-29
5G小科普(漫画版,So easy!)
2019-04-29
无人再提华强北
2019-04-29
千万不要小瞧那些不好好写代码的程序员
2019-04-29
80后,天才程序员, Facebook 第一任 CTO,看看开挂的人生到底有多变态?
2019-04-29
「第四篇」电赛控制题可以准备一些什么?
2019-04-29
「第五篇」全国电子设计竞赛-电源题设计方案总结
2019-04-29
「第六篇」对于电赛,我们应该看重什么?
2019-04-29
树莓派翻车了
2019-04-29
垃圾分类背后的数据和真相
2019-04-29