本文共 4159 字，大约阅读时间需要 13 分钟。

目录

主要知识点

Callable

该接口包含call()方法。可以在该方法中实现任务逻辑。Callable是个泛型接口，所以必须执行call()方法的返回类型。

Future

该接口提供一些方法来获取Callable对象的返回结果和管理Callable对象的状况。

threadPoolExecutor.getCompletedTaskCount()

返回已完成执行的任务的大致总数。因为任务和线程的状态在计算过程中可能会动态变化，所以返回的值只是一个近似值，但在连续调用中不会递减。

0、案例功能

创建10个阶乘任务保存执行结果Future对象，并等待执行完毕，最终把执行结果输出。

一、主函数

package xyz.jangle.thread.test.n4_3.callable0future;import java.util.ArrayList;import java.util.Random;import java.util.concurrent.ExecutionException;import java.util.concurrent.Executors;import java.util.concurrent.Future;import java.util.concurrent.ThreadPoolExecutor;import java.util.concurrent.TimeUnit;/** * 	4.3、在一个执行器中执行任务，并返回结果。 * 	案例功能：创建10个阶乘任务保存执行结果Future对象，并等待执行完毕，最终把执行结果输出。 *  * @author jangle * @email jangle@jangle.xyz * @time 2020年8月18日 下午2:49:10 *  */public class M {	public static void main(String[] args) {		var executorService = (ThreadPoolExecutor) Executors.newFixedThreadPool(2);		var result = new ArrayList
   
    
     >();		var random = new Random();		//	创建10个阶乘计算的对象，提交给执行器执行，并把返回结果存到List中。		for (int i = 0; i < 10; i++) {			int number = random.nextInt(10);			FactorialCalculator factorialCalculator = new FactorialCalculator(number);			Future
     
       future = executorService.submit(factorialCalculator);			result.add(future);		}		// 等待所有线程执行完毕		do {			System.out.println("Main: 线程完成数量：" + executorService.getCompletedTaskCount());			for (int i = 0; i < result.size(); i++) {				Future
      
        future = result.get(i);				System.out.println("Main:Task " + i + ":" + future.isDone());			}			try {				TimeUnit.MILLISECONDS.sleep(50);			} catch (InterruptedException e) {				e.printStackTrace();			}		} while (executorService.getCompletedTaskCount() < result.size());		System.out.println("Main:每个线程的执行结果：");		// 輸出每个线程的执行结果		for (int i = 0; i < result.size(); i++) {			Future
       
         future = result.get(i);			Integer number = null;			try {				number = future.get();			} catch (InterruptedException | ExecutionException e) {				e.printStackTrace();			}			System.out.println("Main:Task" + i + ":" + number);		}		// 停止执行器		executorService.shutdown();	}}
       
      
     
    
   

二、计算阶乘的类

package xyz.jangle.thread.test.n4_3.callable0future;import java.util.concurrent.Callable;import java.util.concurrent.TimeUnit;/** * 	计算number的阶乘 * @author jangle * @email jangle@jangle.xyz * @time 2020年8月18日 下午2:51:06 *  */public class FactorialCalculator implements Callable
   
     {	private final Integer number;	public FactorialCalculator(Integer number) {		super();		this.number = number;	}	@Override	public Integer call() throws Exception {		int result = 1;		if (number == 0 || number == 1) {			result = 1;		} else {			for (int i = 2; i <= number; i++) {				result *= i;				TimeUnit.MILLISECONDS.sleep(20);			}		}		System.out.println(Thread.currentThread().getName() +"数字"+ number+"的阶乘是:" + result);		return result;	}}
   

三、执行结果

Main: 线程完成数量：0pool-1-thread-1数字1的阶乘是:1Main:Task 0:falseMain:Task 1:falseMain:Task 2:falseMain:Task 3:falseMain:Task 4:falseMain:Task 5:falseMain:Task 6:falseMain:Task 7:falseMain:Task 8:falseMain:Task 9:falseMain: 线程完成数量：1Main:Task 0:trueMain:Task 1:falseMain:Task 2:falseMain:Task 3:falseMain:Task 4:falseMain:Task 5:falseMain:Task 6:falseMain:Task 7:falseMain:Task 8:falseMain:Task 9:falsepool-1-thread-1数字4的阶乘是:24Main: 线程完成数量：2Main:Task 0:trueMain:Task 1:falseMain:Task 2:trueMain:Task 3:falseMain:Task 4:falseMain:Task 5:falseMain:Task 6:falseMain:Task 7:falseMain:Task 8:falseMain:Task 9:falsepool-1-thread-1数字3的阶乘是:6pool-1-thread-2数字8的阶乘是:40320pool-1-thread-2数字1的阶乘是:1Main: 线程完成数量：5Main:Task 0:trueMain:Task 1:trueMain:Task 2:trueMain:Task 3:trueMain:Task 4:falseMain:Task 5:trueMain:Task 6:falseMain:Task 7:falseMain:Task 8:falseMain:Task 9:falsepool-1-thread-1数字4的阶乘是:24pool-1-thread-1数字0的阶乘是:1Main: 线程完成数量：7Main:Task 0:trueMain:Task 1:trueMain:Task 2:trueMain:Task 3:trueMain:Task 4:trueMain:Task 5:trueMain:Task 6:falseMain:Task 7:trueMain:Task 8:falseMain:Task 9:falsepool-1-thread-1数字3的阶乘是:6pool-1-thread-1数字0的阶乘是:1pool-1-thread-2数字5的阶乘是:120Main:每个线程的执行结果：Main:Task0:1Main:Task1:40320Main:Task2:24Main:Task3:6Main:Task4:24Main:Task5:1Main:Task6:120Main:Task7:1Main:Task8:6Main:Task9:1

转载地址：http://fbsvb.baihongyu.com/