Java线程池及Future、Callable获得线程返回结果【Java线程池系列2】

简介: Java线程池及Future、Callable获得线程返回结果【Java线程池系列2】Java多线程编程中,经常使用的Thread的Runnable()虽然被经常使用,但其有一个弊端,就是因为无法直接获取该线程的返回值,因为Runnable内的run方法,被定义为void类型,如果开发者需要在线程中处理耗时操作并获得结果,那么必须自己实现一套结果获取的途径,这其实增加了开发者的代码工作量,也可能会因为对线程的不熟悉,造成不必要的代码错误(线程的同步等等问题)。


Java线程池及Future、Callable获得线程返回结果【Java线程池系列2】

Java多线程编程中,经常使用的Thread的Runnable()虽然被经常使用,但其有一个弊端,就是因为无法直接获取该线程的返回值,因为Runnable内的run方法,被定义为void类型,如果开发者需要在线程中处理耗时操作并获得结果,那么必须自己实现一套结果获取的途径,这其实增加了开发者的代码工作量,也可能会因为对线程的不熟悉,造成不必要的代码错误(线程的同步等等问题)。
可是,绝大多情况跑完Java的线程run后,并不是让它啥都不干的void,而是希望获得运行结果。因此,从Java 5开始,Java在语言层级增加了支持线程返回结果的Future、Callable,用以支持和解决上述问题,完事线程编程模型。

先丢出演示代码:

package test_java;

import java.util.ArrayList;
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;

public class ZhangPhilExecutorService {

	private final int NUMBER = 3;

	public ZhangPhilExecutorService() {

		// 创建容量为NUMBER的线程池。
		ExecutorService pool = Executors.newFixedThreadPool(NUMBER);

		ArrayList<Future<String>> futures = new ArrayList<Future<String>>();

		for (int i = 0; i < 10; i++) {

			AThread t = new AThread(i);

			Future<String> f = pool.submit(t);
			futures.add(f);
		}

		System.out.println("获取结果中...");
		for (Future<String> f : futures) {
			try {
				// if(f.isDone())
				System.out.println(f.get());
			} catch (Exception e) {
				e.printStackTrace();
			}
		}
		System.out.println("得到结果.");

		// 关闭线程池。
		pool.shutdown();
	}

	private class AThread implements Callable<String> {

		private int id;

		public AThread(int id) {
			this.id = id;
		}

		@Override
		public String call() {
			System.out.println("线程:" + id + " -> 运行...");

			try {
				Thread.sleep(5000);
			} catch (Exception e) {
				e.printStackTrace();
			}

			System.out.println("线程:" + id + " -> 结束.");

			return "返回的字符串" + id;
		}
	}

	public static void main(String[] args) {
		new ZhangPhilExecutorService();
	}
}


代码很简单。Java的Callable相当于原先线程中的Runnable,但与Runnable中的run()不同的是,Callable中的重载方法call()将返回自定义的泛型结果。
(第一步)首先要定义一个“线程”实现Callable,在Callable穿进去想要获得的泛型结果。
(第二步)然后用Java线程池submit第一步实现的Callable。
(第三步)在第二步中,向Java线程池submit线程时候,返回的Future就是未来要获取线程运行结果的“句柄”。在本例中,跑了10个线程,为了获得这10个线程的结果,那么就建一个Future的ArrayList维护Future。

注意:
(1)Future的get方法在获取结果时候将进入阻塞,阻塞直到Callable中的call返回。
(2)如果不想使得get阻塞,那么可以在get之前加一层判断isDone(),如果完成就获取,如果没有则跳过。

附录我以前写的参考文章
【1】《Java线程池:ExecutorService,Executors》链接地址:http://blog.csdn.net/zhangphil/article/details/43898637

相关文章
|
Java 程序员
Java社招面试中的高频考点:Callable、Future与FutureTask详解
大家好,我是小米。本文主要讲解Java多线程编程中的三个重要概念:Callable、Future和FutureTask。它们在实际开发中帮助我们更灵活、高效地处理多线程任务,尤其适合社招面试场景。通过 Callable 可以定义有返回值且可能抛出异常的任务;Future 用于获取任务结果并提供取消和检查状态的功能;FutureTask 则结合了两者的优势,既可执行任务又可获取结果。掌握这些知识不仅能提升你的编程能力,还能让你在面试中脱颖而出。文中结合实例详细介绍了这三个概念的使用方法及其区别与联系。希望对大家有所帮助!
703 60
|
10月前
|
人工智能 Java API
Java并发编程之Future与FutureTask
本文深入解析了Future接口及其实现类FutureTask的原理与使用。Future接口定义了获取任务结果、取消任务及查询任务状态的规范,而FutureTask作为其核心实现类,结合了Runnable与Future的功能。文章通过分析FutureTask的成员变量、状态流转、关键方法(如run、set、get、cancel等)的源码,展示了异步任务的执行与结果处理机制。最后,通过示例代码演示了FutureTask的简单用法,帮助读者更直观地理解其工作原理。适合希望深入了解Java异步编程机制的开发者阅读。
200 0
|
Prometheus 监控 Cloud Native
JAVA线程池监控以及动态调整线程池
【10月更文挑战第22天】在 Java 中,线程池的监控和动态调整是非常重要的,它可以帮助我们更好地管理系统资源,提高应用的性能和稳定性。
851 64
|
监控 Java 数据库连接
Java线程管理:守护线程与用户线程的区分与应用
在Java多线程编程中,线程可以分为守护线程(Daemon Thread)和用户线程(User Thread)。这两种线程在行为和用途上有着明显的区别,了解它们的差异对于编写高效、稳定的并发程序至关重要。
400 2
|
监控 Java 开发者
Java线程管理:守护线程与本地线程的深入剖析
在Java编程语言中,线程是程序执行的最小单元,它们可以并行执行以提高程序的效率和响应性。Java提供了两种特殊的线程类型:守护线程和本地线程。本文将深入探讨这两种线程的区别,并探讨它们在实际开发中的应用。
210 1
JAVA并发编程系列(13)Future、FutureTask异步小王子
本文详细解析了Future及其相关类FutureTask的工作原理与应用场景。首先介绍了Future的基本概念和接口方法,强调其异步计算特性。接着通过FutureTask实现了一个模拟外卖订单处理的示例,展示了如何并发查询外卖信息并汇总结果。最后深入分析了FutureTask的源码,包括其内部状态转换机制及关键方法的实现原理。通过本文,读者可以全面理解Future在并发编程中的作用及其实现细节。
|
Java
Java线程池核心数为0时,线程池如何执行?
【8月更文挑战第11天】Java线程池核心数为0时,线程池如何执行?
693 1
Jstack 查看线程状态及定位占用 cpu 较高的 java 线程
Jstack 查看线程状态及定位占用 cpu 较高的 java 线程
1577 2
|
监控 Java 调度
Java面试题:描述Java线程池的概念、用途及常见的线程池类型。介绍一下Java中的线程池有哪些优缺点
Java面试题:描述Java线程池的概念、用途及常见的线程池类型。介绍一下Java中的线程池有哪些优缺点
365 1
|
Java 调度
Java面试题:简述Java线程的生命周期及其状态转换。
Java面试题:简述Java线程的生命周期及其状态转换。
127 0

热门文章

最新文章