Java多线程(案例+解析)JDK5.0新增的线程的创建方式
1、●JDK 5.0起提供了线程池相关API:
2、●
3、●
发布日期:2021-06-29 15:03:05
浏览次数:3
分类:技术文章
本文共 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 如侵犯您的版权,请留言回复原文章的地址,我们会给您删除此文章,给您带来不便请您谅解!
发表评论
最新留言
留言是一种美德,欢迎回访!
[***.207.175.100]2024年04月29日 12时45分14秒
关于作者
喝酒易醉,品茶养心,人生如梦,品茶悟道,何以解忧?唯有杜康!
-- 愿君每日到此一游!
推荐文章
docker系列2: windows安装docker
2019-04-29
hbase数据转移: 导入导出
2019-04-29
docker系列7: docker搭建mysql
2019-04-29
windows server 2012设置远程连接断开后自动注销
2019-04-29
python基础:list,map,open()文件读写
2019-04-29
Go面向对象-接口
2019-04-29
Go-多路选择和超时控制
2019-04-29
Go-channel的关闭和广播
2019-04-29
Go-任务的取消
2019-04-29
AIX 作为Web Server 使用时,tcp相关的几个参数调整
2019-04-29
自我学习37:请描述一下网页从开始请求到最后展示的完整过程
2019-04-29
自我学习38:如何区分前后端BUG
2019-04-29
自我学习39:接口自动化测试用例&功能测试用例区别
2019-04-29
mirror去兔子补丁下载 附安装教程
2019-04-29
mirror去兔子补丁 v3.0附安装教程
2019-04-29
mirror去兔子补丁为什么还有兔子_mirror去兔子补丁使用教程
2019-04-29
3dmax2012安装教程
2019-04-29
OC渲染器(Octane Render)整合版安装包 附安装教程
2019-04-29
操作系统期末大题复习
2019-04-29
hive:分区表,hbase外表
2019-04-29