Java多线程Callable和Future类详解
2024-08-25 01:52:01
public interface Callable<V> 返回结果并且可能抛出异常的任务。实现者定义了一个不带任何参数的叫做 call 的方法
public interface Future<V> Future 表示异步计算的结果。计算完成后只能使用 get 方法来获取结果
1.线程处理返回结果
一般开发中,使用多线程,最常见的就是:1.实现Runnable接口;2.继承Thread类。
但是run方法是没有返回结果,很难满足我们的需求。这时,常用的办法就是实现Callable接口
Callable接口提供了一个call方法入口,我们可以通过实现call方法,来执行任务;这个接口支持泛型,可以通过泛型参数,来获取想要的结果类型
2.关闭线程池
可以通过调用线程池的shutdown或shutdowNow方法来关闭线程池,但是它们的实现原理不同。
shutdown的原理只是将线程池的状态设置SHUTDOWN状态,然后中断没有开始执行任务的线程。
shutdownNow的原理是遍历线程池中的工作线程,然后逐个调用线程的interrupt方法来中断线程,所以需要注意一点,如果存在无法响应中断的任务,可能永远无法终止。shutdownNow会首先将线程池的状态设置成STOP,然后尝试停止所有的正在执行或暂停任务的线程,并返回等待执行任务的列表
package com.yyx.test; import java.util.concurrent.Callable; public class MyCallable implements Callable<String> { private String name; public MyCallable(String name) {
this.name = name;
} @Override
public String call() throws Exception {
return name + "任务返回的内容";
} }
package com.yyx.test; import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future; public class CallableFutureTest {
public static void main(String[] args) {
try {
// 创建一个线程池
ExecutorService pool=Executors.newCachedThreadPool(); // 创建多个有返回值的任务
List<Future> listFuture=new ArrayList<Future>();
for(int i=1;i<=5;i++) {
Callable c = new MyCallable("第"+i + "个线程");
// 执行任务并获取Future对象
Future f = pool.submit(c);
//判断Future对象是否已经完成
if (f.isDone()) {
listFuture.add(f);
}
} // 关闭线程池
pool.shutdown(); // 获取所有并发任务的运行结果
for (Future future : listFuture) {
// 从Future对象上获取任务的返回值,并输出到控制台
System.out.println(">>>" + future.get().toString());
}
} catch (Exception e) {
e.printStackTrace();
}
}
}
最新文章
- Node.js学习笔记——Node.js开发Web后台服务
- 编译器开发系列--Ocelot语言4.类型定义的检查
- [Hadoop in Action] 第4章 编写MapReduce基础程序
- 【转】Thread.isBackground
- September 29th 2016 Week 40th Thursday
- 菜鸟学Linux命令:端口查看和操作命令
- Map的数据结构
- 数据库中is null(is not null)与=null(!=null)的区别
- Animator组件关闭再打开后参数丢失问题
- python 批量爬取代理ip
- sql server 2008 修改sa密码
- windows 7 ssh server for scp
- wan口mac=lan口mac加一,wlan是lan口mac加二
- __read_mostly变量含义
- 启用composer镜像服务
- RESTful 规范
- Kali学习笔记16:Nmap详细讲解
- 第一册:lesson ninety-three。
- redhat7.3安装python3 pip3
- JavaScript基础视频教程总结(021-030章)