java Callable与Future模式

Mr_zhang 发布于2019-08-16 17:47 / 1535人阅读

摘要：然而，这两种方式的缺点是在线程任务执行结束后，无法获取执行结果。如果任务执行结束，无论是正常结束或是中途取消还是发生异常，都返回。如果任务完成前被取消，则返回。参数表示是否中断执行中的线程。

在Java中，创建线程一般有两种方式，一种是继承Thread类，一种是实现Runnable接口。然而，这两种方式的缺点是在线程任务执行结束后，无法获取执行结果。我们一般只能采用共享变量或共享存储区以及线程通信的方式实现获得任务结果的目的。不过，Java中，也提供了使用Callable和Future来实现获取任务结果的操作。Callable用来执行任务，产生结果，而Future用来获得结果。

Future常用方法：
V get() ：获取异步执行的结果，如果没有结果可用，此方法会阻塞直到异步计算完成。
V get(Long timeout , TimeUnit unit) ：获取异步执行结果，如果没有结果可用，此方法会阻塞，但是会有时间限制，如果阻塞时间超过设定的timeout时间，该方法将抛出异常。
boolean isDone() ：如果任务执行结束，无论是正常结束或是中途取消还是发生异常，都返回true。
boolean isCanceller() ：如果任务完成前被取消，则返回true。
boolean cancel(boolean mayInterruptRunning) ：如果任务还没开始，执行cancel(...)方法将返回false；如果任务已经启动，执行cancel(true)方法将以中断执行此任务线程的方式来试图停止任务，如果停止成功，返回true；当任务已经启动，执行cancel(false)方法将不会对正在执行的任务线程产生影响(让线程正常执行到完成)，此时返回false；当任务已经完成，执行cancel(...)方法将返回false。mayInterruptRunning参数表示是否中断执行中的线程。
通过方法分析我们也知道实际上Future提供了3种功能：（1）能够中断执行中的任务（2）判断任务是否执行完成（3）获取任务执行完成后额结果。

定义thread

public class CallThread implements Callable {

    @Override
    public String call() throws InterruptedException {
        Thread.sleep(1000);
        return "callable and future";
    }
}

测试

@RequestMapping("test-call")
    public void testCall() {
        CallThread callThread = new CallThread();
        ExecutorService executor = Executors.newCachedThreadPool();
        Future submit = executor.submit(callThread);
        try {
            String s = submit.get();
            System.out.println("获取结果：" + s);
        } catch (InterruptedException e) {
            e.printStackTrace();
        } catch (ExecutionException e) {
            e.printStackTrace();
        }

    }

云服务器 GPU云服务器 java与模式 Future Callable 模式识别与图像识别

文章版权归作者所有，未经允许请勿转载,若此文章存在违规行为，您可以联系管理员删除。

转载请注明本文地址：https://www.ucloud.cn/yun/74740.html

Java多线程进阶（四二）—— J.U.C之executors框架：Future模式

摘要：本文首发于一世流云的专栏一模式简介模式是多线程设计模式中的一种常见模式，它的主要作用就是异步地执行任务，并在需要的时候获取结果。二中的模式在多线程基础之模式中，我们曾经给出过模式的通用类关系图。 showImg(https://segmentfault.com/img/bVbiwcx?w=1000&h=667); 本文首发于一世流云的专栏：https://segmentfault.co...

marek 2019-08-16 13:29 评论0 收藏0
Think In Java 读书笔记:Concurrency

摘要：类是一种有效的广泛使用的以工作队列为基础的的线程池的正确实现，无须尝试编写自己的线程池这样容易出错。是并发编程库新添加的类它提供的方法可以返回各线程的返回值与接口类似于但是无法返回结果也无法返回异常。返回的结果可以被拿到。 package com.snda.sync.impl.test; import java.util.ArrayList; import java.util.con...

DevTTL 2019-08-14 11:44 评论0 收藏0
Java 8 并发教程：线程和执行器

摘要：在这个示例中我们使用了一个单线程线程池的。在延迟消逝后，任务将会并发执行。这是并发系列教程的第一部分。第一部分线程和执行器第二部分同步和锁第三部分原子操作和 Java 8 并发教程：线程和执行器原文：Java 8 Concurrency Tutorial: Threads and Executors 译者：BlankKelly 来源：Java8并发教程：Threads和Execut...

jsdt 2019-08-14 14:22 评论0 收藏0
【Java并发】Runnable、Callable、Future、FutureTask

摘要：声明了几种方法，其中有一个就是传入声明了对具体的或者任务执行进行取消查询结果获取等方法。事实上，是接口的一个唯一实现类。使用示例第一种方式是使用继承了的线程池中的方法，将直接提交创建。创建线程的两种方式直接继承 Thread 实现 Runnable 接口这两种方式都有一个缺点：在执行完成任务之后，无法直接获取到最后的执行结果。如果需要获取执行结果，就必须通过共享变量或线程通...

zhaot 2019-08-19 11:01 评论0 收藏0
Java多线程-Callable和Future

摘要：类提供了一些有用的方法在线程池中执行内的任务。在线程池提交任务后返回了一个对象，使用它可以知道任务的状态和得到返回的执行结果。 Callable和Future出现的原因创建线程的2种方式，一种是直接继承Thread，另外一种就是实现Runnable接口。这2种方式都有一个缺陷就是：在执行完任务之后无法获取执行结果。如果需要获取执行结果，就必须通过共享变量或者使用线程通信的方式来达...

seasonley 2019-08-19 11:32 评论0 收藏0