J.U.C系列（四）FutrueTask的使用

小半 • 2023年1月11日下午2:13 • 技术随笔 • 阅读 193

FutureTask
FutureTask实现了RunnableFuture接口，RunnableFuture接口继承于Runnable, Future<V>
这使得FutureTask既可以当做一个任务执行，也可以有返回值。

public class FutureTask<V> implements RunnableFuture<V>

public interface RunnableFuture<V> extends Runnable, Future<V>

FutureTask可以用在需要异步获取执行结果或者需要取消执行任务的场景，比如一个任务需要耗时很长，但是超过一定时长需要取消的场景，或者这个任务耗时比较长，等主线程完成自己的任务之后再去获取FutureTask返回的执行结果。
测试代码如下：

package com.leo.demo.juctest;

import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.FutureTask;
import java.util.concurrent.TimeUnit;

/**
 * @ClassName: FutureTaskExample
 * @Description: 关于FutureTask的测试
 * @Author: leo825
 * @Date: 2020-05-11 13:19
 * @Version: 1.0
 */
public class FutureTaskExample {

    public static void main(String[] args) throws ExecutionException, InterruptedException {
        getThreadLog("主线程开始启动...");
        FutureTask<Integer> futureTask = new FutureTask<>(() -> {
            int result = 0;
            for (int i = 0; i < 100; i++) {
                TimeUnit.MILLISECONDS.sleep(10);
                result += i;
            }
            getThreadLog("futureTask执行完开始返回结果：" + result);
            return result;
        });

        //定义一个线程去执行计算
        Thread cmpThread = new Thread(futureTask);
        cmpThread.start();

        //主线程调用其他异步线程去执行任务
        Thread otherThread = new Thread(() -> {
            try {
                int costTime = 2;
                getThreadLog("模拟调用时长" + costTime + "s");
                TimeUnit.SECONDS.sleep(costTime);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        });
        otherThread.start();
        //主线程等待futureTask返回执行结果
        getThreadLog("主线程开始等待futureTask返回结果：" + futureTask.get());
    }

    /**
     * 获取线程名和时间
     *
     * @return
     */
    public static void getThreadLog(String logContent) {
        StringBuffer stringBuffer = new StringBuffer();
        stringBuffer.append("[");
        stringBuffer.append(Thread.currentThread().getName());
        stringBuffer.append(" ");
        stringBuffer.append(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss.SSS").format(new Date()));
        stringBuffer.append("]");
        stringBuffer.append(logContent);
        System.out.println(stringBuffer.toString());
    }
}

执行结果：

[main 2020-05-11 13:44:06.991]主线程开始启动...
[Thread-1 2020-05-11 13:44:07.129]模拟调用时长2s
[Thread-0 2020-05-11 13:44:08.314]futureTask执行完开始返回结果：4950
[main 2020-05-11 13:44:08.315]主线程开始等待futureTask返回结果：4950

文章由极客之音整理，本文链接：https://www.bmabk.com/index.php/post/72710.html

J.U.C系列（四）FutrueTask的使用

相关推荐