Java中的FutureTask實現(xiàn)異步任務代碼實例

更新時間：2024年01月15日 09:41:57 作者：Mu_Mu是一只小白

這篇文章主要介紹了Java中的FutureTask實現(xiàn)異步任務代碼實例,普通的線程執(zhí)行是無法獲取到執(zhí)行結(jié)果的,FutureTask?間接實現(xiàn)了?Runnable?和?Future?接口,可以得到子線程耗時操作的執(zhí)行結(jié)果,AsyncTask?異步任務就是使用了該機制,需要的朋友可以參考下

FutureTask實現(xiàn)異步任務

FutureTask 的執(zhí)行結(jié)果和出現(xiàn)異常的異常對象都會被放到outcome對象中，通過get()方法返回。

1.測試future任務正常返回

public class T2 {
    ThreadFactory namedThreadFactory = new ThreadFactoryBuilder().setNamePrefix("thread-start-runner").build();
    ExecutorService taskExe = new ThreadPoolExecutor(10, 20, 800L, TimeUnit.MILLISECONDS, new LinkedBlockingQueue<>(100), namedThreadFactory);
    private static final Logger LOG = LoggerFactory.getLogger(T2.class);
    @Test
    public void test2() {
        List<FutureTask<Integer>> taskList = new ArrayList<>();
        for (int i = 0; i < 10; i++) {
            final int a = i;
            FutureTask<Integer> futureTask = new FutureTask<>(() -> {
                LOG.info("正在進行第" + a + "個任務");
                Thread.sleep(3000);
                return 1;
            });
            taskList.add(futureTask);
            //異步執(zhí)行
            taskExe.submit(futureTask);
        }
        LOG.info("任務添加完成");
        int count = 0;
        try {
            for (FutureTask<Integer> task : taskList) {
                /*
                FutureTask執(zhí)行的結(jié)果會放入它的私有變量outcome中，其他線程直接調(diào)用futureTask.get()去讀取該變量即可
                會阻塞直到單個任務執(zhí)行完畢
                * */
                Integer value = task.get();
                LOG.info("value:" + value);
                count += value;
            }
        } catch (InterruptedException e) {
            LOG.error("線程執(zhí)行被中斷", e);
        } catch (ExecutionException e) {
            LOG.error("線程執(zhí)行出現(xiàn)異常", e);
        }
        taskExe.shutdown();
        LOG.info("count:" + count);
    }```

執(zhí)行結(jié)果：正常累加。

在這里插入圖片描述

2.測試future任務異常返回，通過get()方法拿到異常

@Test
    public void test3() {
        List<FutureTask<Integer>> taskList = new ArrayList<>();
        for (int i = 0; i < 10; i++) {
            final int a = i;
            FutureTask<Integer> futureTask = new FutureTask<>(() -> {
                LOG.info("正在進行第" + a + "個任務");
                int v=1/0;
                return 1;
            });
            taskList.add(futureTask);
            //異步執(zhí)行
            taskExe.submit(futureTask);
        }
        LOG.info("任務添加完成");
        int count = 0;
        try {
            for (FutureTask<Integer> task : taskList) {
                /*
                FutureTask執(zhí)行的結(jié)果會放入它的私有變量outcome中（包括異常），其他線程直接調(diào)用futureTask.get()去讀取該變量即可
                會阻塞直到單個任務執(zhí)行完畢
                * */
                Integer value = task.get();
                LOG.info("value:" + value);
                count += value;
            }
        } catch (InterruptedException e) {
            LOG.error("線程執(zhí)行被中斷", e);
        } catch (ExecutionException e) {
            LOG.error("線程執(zhí)行出現(xiàn)異常", e);
        }
        taskExe.shutdown();
        LOG.info("count:" + count);
}

執(zhí)行結(jié)果：捕獲到異常。

在這里插入圖片描述

3.callable出現(xiàn)異常，不進行g(shù)et()

   @Test
    public void test4() {
        List<FutureTask<Integer>> taskList = new ArrayList<>();
        for (int i = 0; i < 10; i++) {
            final int a = i;
            FutureTask<Integer> futureTask = new FutureTask<>(() -> {
                LOG.info("正在進行第" + a + "個任務");
                int v = 1 / 0;
                return 1;
            });
            taskList.add(futureTask);
            //異步執(zhí)行
            taskExe.submit(futureTask);
        }
        LOG.info("任務添加完成");
        taskExe.shutdown();
    }

執(zhí)行結(jié)果：沒有拋出異常。

在這里插入圖片描述