如何在Java中使用FutureTask实现多线程？相信很多没有经验的人对此束手无策，为此本文总结了问题出现的原因和解决方法，通过这篇文章希望你能解决这个问题。
FutureTask属于java.util.concurrent 包；FutureTask表示可取消的异步计算。FutureTask类提供了一个Future的基本实现 ，具有启动和取消计算的方法，查询计算是否完整，并检索计算结果。结果只能在计算完成后才能检索; 如果计算尚未完成，则get方法将阻止。 一旦计算完成，则无法重新启动或取消计算（除非使用runAndReset()调用计算 ）。
从上面的FutureTask类图中可以看出，FutureTask实现了RunnableFuture接口，RunnableFuture接口继承了Runnable接口和Future接口，所以FutureTask兼备Runnable和Future两种特性
1、构造方法
public FutureTask(Callable callable) 创建一个 FutureTask ，它将在运行时执行给定的 Callable 。 参数： callable表示可调用任务 。
public FutureTask(Runnable runnable,V result) 创建一个 FutureTask ，将在运行时执行给定的 Runnable ，并安排 get将在成功完成后返回给定的结果。 参数：runnable 表示可运行的任务 ；result 表示成功完成后返回的结果。
2、常用的方法
public boolean isCancelled() 如果此任务在正常完成之前取消，则返回 true 。
public boolean isDone() 返回true如果任务已完成。
public V get() 等待计算完成，然后检索其结果。
public V get(long timeout, TimeUnit unit)如果需要等待最多在给定的时间计算完成，然后检索其结果（如果可用）。
public boolean cancel(boolean mayInterruptIfRunning)尝试取消执行此任务。
protected void set(V v)将此未来的结果设置为给定值，除非此未来已被设置或已被取消。
示例参考此博文：Java FutureTask类使用
案例场景
通过示例进行多任务计算，通过get()方法可以异步获取执行结果。
1、创建一个计算任务类，实现Callable接口,重写call方法
package com.xz.thread.FutureTask; import java.util.concurrent.Callable; /** * @description: 创建一个计算任务类，实现Callable接口,重写call方法 * @author: xz * @create: 2021-06-02 22:06 */ public class ComputeTask implements Callable<Integer> { private String taskName;//任务名称 //任务构造器 public ComputeTask(String taskName) { this.taskName = taskName; System.out.println("创建【计算任务】开始，计算任务名称：" + taskName); } //计算任务的方法 @Override public Integer call() throws Exception { Integer result = 0; for (int i = 1; i <=50; i++) { result = +i; } System.out.println("【计算任务】"+taskName +"执行完成。"); return result; } }2、创建一个测试类
package com.xz.thread.FutureTask; import java.util.ArrayList; import java.util.List; import java.util.concurrent.ExecutionException; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.FutureTask; /** * @description: * @author: xz * @create: 2021-06-01 22:44 */ public class Demo { public static void main(String[] args) { //任务集合 List<FutureTask<Integer>> futureTasks = new ArrayList<>(); //创建固定长度的线程池 ExecutorService pool = Executors.newFixedThreadPool(5); for (int i = 1; i <= 10; i++) { //实例化FutureTask，传入计算任务类 FutureTask<Integer> futureTask = new FutureTask<>(new ComputeTask(i + "")); //添加到任务集合中 futureTasks.add(futureTask); //提交任务到线程池 pool.submit(futureTask); } System.out.println("所有【计算任务】提交完毕，主线程开始执行"); System.out.println("【主线程任务】开始============"); //主线程睡眠5秒，模拟主线程做某些任务 try { Thread.sleep(5000); System.out.println("【主线程任务】开始执行某些任务============"); } catch (InterruptedException e) { e.printStackTrace(); } System.out.println("【主线程任务】结束============"); //用于打印任务执行结果 Integer result = 0; for (FutureTask<Integer> task : futureTasks) { try { //FutureTask的get()方法会自动阻塞，知道得到任务执行结果为止 result += task.get(); } catch (InterruptedException e) { e.printStackTrace(); } catch (ExecutionException e) { e.printStackTrace(); } } //关闭线程池 pool.shutdown(); System.out.println("多线程多任务执行结果：" + result); } }3、输出结果如下：
创建【计算任务】开始，计算任务名称：1
创建【计算任务】开始，计算任务名称：2
创建【计算任务】开始，计算任务名称：3
创建【计算任务】开始，计算任务名称：4
创建【计算任务】开始，计算任务名称：5
创建【计算任务】开始，计算任务名称：6
创建【计算任务】开始，计算任务名称：7
创建【计算任务】开始，计算任务名称：8
创建【计算任务】开始，计算任务名称：9
创建【计算任务】开始，计算任务名称：10
所有【计算任务】提交完毕，主线程开始执行
【主线程任务】开始============
【计算任务】1执行完成。
【计算任务】2执行完成。
【计算任务】6执行完成。
【计算任务】7执行完成。
【计算任务】9执行完成。
【计算任务】10执行完成。
【计算任务】8执行完成。
【计算任务】4执行完成。
【计算任务】3执行完成。
【计算任务】5执行完成。
【主线程任务】开始执行某些任务============
【主线程任务】结束============
多线程多任务执行结果：500
看完上述内容，你们掌握如何在Java中使用FutureTask实现多线程的方法了吗？如果还想学到更多技能或想了解更多相关内容，欢迎关注亿速云行业资讯频道，感谢各位的阅读！
免责声明：本站发布的内容（图片、视频和文字）以原创、转载和分享为主，文章观点不代表本网站立场，如果涉及侵权请联系站长邮箱：is@yisu.com进行举报，并提供相关证据，一经查实，将立刻删除涉嫌侵权内容。
