首页 > 编程语言 >JAVA异步编程之Callbacks与Futures模型

JAVA异步编程之Callbacks与Futures模型

时间:2023-03-24 13:55:43浏览次数:60  
标签:异步 JAVA Thread Futures System Callbacks 线程 println out

JAVA异步编程之Callbacks与Futures模型

一:Callbacks模型

​ 该模型的异步方法,在异步任务完成之后调用,主线程没有异步线程的结果。经典模型如Swing’s EventListener模型(如果不了解可参考html如何实现button的click方法)

1.1:示例

public class CallbackModel implements Callback, Runnable {
    @Override
    public void invoke() {
        System.out.println("这是异步回调的结果");
    }
    @Override
    public void run() {
        try {
            System.out.println(Thread.currentThread().getName() + "::异步线程任务开始");
            Thread.sleep(1000);
            System.out.println(Thread.currentThread().getName() + "::异步线程任务结束");
            invoke();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
    public static void main(String[] args) {
        System.out.println(Thread.currentThread().getName() + "::主线程开始");
        new Thread(new CallbackModel(), "线程一").start();
        System.out.println(Thread.currentThread().getName() + "::主线程结束");
    }
}
interface Callback {
    void invoke();
}

1.2: 运行结果

main::主线程开始
main::主线程结束
线程一::异步线程任务开始
线程一::异步线程任务结束
这是异步回调的结果

二:Futures模型

​ 该模型的异步方法,立刻返回一个包装了结果的返回值Future,T即是包装的返回值,但返回值不可立即访问(异步方法为完成),Future对象包装了对它的访问。可以轮询对象,直到该值可用为止。

2.1 用例

public class FutureModel {

    static class FutureTask implements Callable {

        @Override
        public Object call()  {
            try {
                System.out.println(Thread.currentThread().getName() + "::异步线程任务开始");
                Thread.sleep(4000);
                System.out.println(Thread.currentThread().getName() + "::异步线程任务结束");
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            return "1234";
        }
    }


    public static void main(String[] args) {
        ExecutorService pool = Executors.newSingleThreadExecutor();
        Future<String> submit = pool.submit(new FutureTask());
        try {
            System.out.println(Thread.currentThread().getName() + "返回的结果::" + submit.get());
        } catch (InterruptedException e) {
            e.printStackTrace();
        } catch (ExecutionException e) {
            e.printStackTrace();
        }finally {
            pool.shutdown();
        }
    }
}

2.1 用例结果:

pool-1-thread-1::异步线程任务开始
pool-1-thread-1::异步线程任务结束
main返回的结果::1234

三:Future接口

/**
*异步计算的结果
*/
public interface Future<V> {

    /**
     * 尝试取消任务,有可能失败
     */
    boolean cancel(boolean mayInterruptIfRunning);

    /**
     * 判断是否取消
     *
     * @return {@code true} if this task was cancelled before it completed
     */
    boolean isCancelled();

    /**
     *  * 判断是否完成
     *
     * @return {@code true} if this task completed
     */
    boolean isDone();

    /**
     * 等待直至获取结果
     */
    V get() throws InterruptedException, ExecutionException;

    /**
     * 等待指定的时间获取结果,否则抛出异常
     */
    V get(long timeout, TimeUnit unit)
        throws InterruptedException, ExecutionException, TimeoutException;
}

四:小结

1.两种模型还是基于java的Runnable接口和Callable接口

2.Runnable接口配合Thread创建线程,通常不关注返回结果。

3.Callable接口配合Executors(java提供的线程池管理工具)与Future(封装返回结果),常用场景是主线程需要获取异步的结果。

原创连接: http://121.5.70.195/articles/151
参考文献1: https://projectreactor.io/docs/core/release/reference/index.html#_asynchronicity_to_the_rescue
参考文献2: Future源码注释

标签:异步,JAVA,Thread,Futures,System,Callbacks,线程,println,out
From: https://www.cnblogs.com/jinliang374003909/p/17251329.html

相关文章

  • java MD5加密
    参考文章:http://warren.iteye.com/blog/107386---------------------------------------------------------------------------------------------------------------------......
  • java-Object的通用方法:equals()、hashCode()、toString()、clone()
    1/**2*Object通用方法:equals()、hashCode()、toString()、clone()3*/4@Data5@NoArgsConstructor6@AllArgsConstructor7publicclassobje......
  • vue全家桶进阶之路2:JavaScript
    JavaScript(简称“JS”)是当前最流行、应用最广泛的客户端脚本语言,用来在网页中添加一些动态效果与交互功能,在Web开发领域有着举足轻重的地位。JavaScript与HTML和CSS......
  • JavaScript的数学计算库:decimal.js
    阅读目录官网文档decimal.js特性安装实例代码加减乘除官网文档文档:https://mikemcl.github.io/decimal.js/github:https://github.com/MikeMcl/decimal.jsnpm地址:https......
  • JavaScript RegExp 对象
    阅读目录RegExp对象修饰符JavaScriptRegExpi修饰符JavaScriptRegExpg修饰符方括号JavaScriptRegExp[abc]表达式JavaScriptRegExp[^abc]表达式元字符JavaScript......
  • 包机制和JavaDoc
    包机制为了更好的组织类,用于区别类名的命名空间.包语句的语法格式为:packagepkg1[.pkg2[.pkge...]];一般利用公司域名倒置作为包名;com.baidu.wwwimport导......
  • Java运算符
    运算符算术运算符:++关系运算符:instanceof逻辑运算符:&&,||,!与或非位运算符:&|^~>>,<<,>>>条件运算符:?:Stringtype=score<60......
  • java环境变量设置
    java环境变量设置目录java环境变量设置一、windows系统1.1、进入高级系统设置1.2、进入环境变量界面1.3、新增JAVA_HOME变量1.4、新增CLASSPATH变量1.5、新增Path变量1.6......
  • Java操作Elasticsearch 之 [Java High Level REST Clientedit]
    <aname="VbjtD"></a>1.简述Elasticsearch是基于Lucene开发的一个分布式全文检索框架,向Elasticsearch中存储和从Elasticsearch中查询,格式是json。向Elasticsearch......
  • Java高级开发必会的50个性能优化的细节
    在JAVA程序中,性能问题的大部分原因并不在于JAVA语言,而是程序本身。养成良好的编码习惯非常重要,能够显著地提升程序性能。●1.尽量在合适的场合使用单例如果想学习Java工程......