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

相关文章
|
4天前
|
存储 SQL 监控
JAVA 线程池的分析和使用
JAVA 线程池的分析和使用
10 0
|
4天前
|
监控 安全 Java
深入理解Java线程池:ThreadPoolExecutor
深入理解Java线程池:ThreadPoolExecutor
9 0
|
2天前
|
缓存 NoSQL Java
Java高并发实战:利用线程池和Redis实现高效数据入库
Java高并发实战:利用线程池和Redis实现高效数据入库
12 0
|
5天前
|
Java
|
5天前
|
分布式计算 Java Spark
|
1月前
|
Java 调度
Java并发编程:深入理解线程池的原理与实践
【4月更文挑战第6天】本文将深入探讨Java并发编程中的重要概念——线程池。我们将从线程池的基本原理入手,逐步解析其工作过程,以及如何在实际开发中合理使用线程池以提高程序性能。同时,我们还将关注线程池的一些高级特性,如自定义线程工厂、拒绝策略等,以帮助读者更好地掌握线程池的使用技巧。
|
9月前
|
算法 Java 调度
Java由浅入深理解线程池设计和原理1
Java由浅入深理解线程池设计和原理1
147 0
|
17天前
|
监控 Java 调度
Java并发编程:线程池的原理与实践
【5月更文挑战第30天】 在现代软件开发中,尤其是Java应用中,并发编程是一个不可忽视的领域。线程池作为提升应用性能和资源利用率的关键技术之一,其正确使用和优化对系统稳定性和效率至关重要。本文将深入探讨线程池的核心原理、常见类型以及在实际开发中的使用案例,旨在帮助开发者更好地理解和运用线程池技术,构建高性能的Java应用程序。
|
18天前
|
监控 Java 开发者
深入理解Java并发编程:线程池的工作原理与实践
【5月更文挑战第29天】 在现代Java应用开发中,高效地管理并发任务是至关重要的。本文将深入探讨Java线程池的核心机制,揭示其背后的设计哲学和运作模式。通过分析线程池的优势、工作过程及关键参数,结合实例演示如何合理配置和优化线程池以提高应用程序的性能和响应能力。
|
18天前
|
Java 开发者
Java并发编程:理解线程池的工作原理与实践应用
【5月更文挑战第29天】在Java并发编程中,线程池是一种管理线程资源的重要工具。通过深入探讨线程池的工作原理和实践应用,本文将帮助开发者更好地理解和使用线程池,提高系统性能和稳定性。