• Scala 中应用 Future 并发编程

    calendar Dec 13, 2017   ---   · 3 min read · Future Concurreent  ·
    Share on: linkedin copy
    Scala 中应用 Future 并发编程

    Java 世界里进行并发编程有 Future 和  ExecutorService(当成 ThreadPool 来对待)，及至 Java 8 引入了更为趁手的 CompletableFuture。那么使用 Scala 该如何进行并发编程呢？Scala 能毫无障碍的使用 Java 类库，所以完全可以用 Java 的 API 来使用线程池，只是那不太 Scala 罢了。

    既然是 Scala, 就尽量写成 Scala Style 吧，Scala 也有自己的 Future, 还有 Promise 呢? 至于 Promise 与 Future 多大区别，语义上似乎也差不多，只看到 Promise 中有一个 Future 的属性。如果想玩得高级一点的话就该把  Actor 弄起来，它算是所谓的纤程，多个  Actor 可跑在同一个线程中，当然启动要快，内存消耗少，还避免了上下文切换。

    这里还是先体验 Scala Future 的用法。Future 本身只是描述了一个任务，及将要获得的结果(或执行的动作)，因此那样一个任务也是要放到线程池中去执行。这和 Java 的 Future/ThreadPool 是一样的概念。稍有不同的是线程池的创建与使用，线程池的默认大小配置等。看个简单的应用示例，本次测试的 Scala 版本是 2.11.12，为了突出实际的线程池大小，我们把任务数设置为 20 个

    Scala Future 并发编程体验

    Read More

  • CompletableFuture 的并发性能研究

    calendar Dec 29, 2016   ---   · 4 min read · java8 Future CompletableFuture  ·
    Share on: linkedin copy
    CompletableFuture 的并发性能研究
    今天继续探讨 CompletableFuture 的特性，它并发时的性能如何呢？我们知道集合的 stream() 后的操作是序列化进行的，parallelStream()是能够并发执行的，而用 CompletableFuture 可以更灵活的控制并发。


    我们先可以对比一下 parallelStream() 与 CompletableFuture 的性能差异

    假设一个这样的耗时 1000 毫秒的计算任务
    1private static int getJob() {
2    try {
3        Thread.sleep(1000);
4    } catch (InterruptedException e) {
5    }
6    return 50;
7}

    分别用下面两个方法来测试，任务数可以通过参数来控制 Read More

  • 理解 CompletableFuture 的任务与回调函数的线程

    calendar Dec 23, 2016   ---   · 4 min read · java8 Future CompletableFuture CompletionStage  ·
    Share on: linkedin copy
    理解 CompletableFuture 的任务与回调函数的线程
    继续对 CompletableFuture 的学习，本然依然不对它的众多方法的介绍，其实也不容易通过一篇述说完所有 CompletableFuture 的操作。此处重点了解下 CompletableFuture 几类操作时所使用的线程，CompletableFuture 的方法重点在它的静态方法以及实现自 CompletionStage 接口的方法，如果是意图异步化编程，反而自我标榜的 Future 中的方法用的少了。


    CompletableFuture 根据任务的主从关系为
    1. 提交任务的方法，如静态方法 supplyAsync(supplier[, executor]),  runAsync(runnable[, executor])
    2. 回调函数，即对任务执行后所作出回应的方法，多数方法了，如 thenRun(action), thenRunAsync(action[, executor]), whenComplete(action), whenCompleteAsync(action[, executor]) 等

    根据执行方法可分为同步与异步方法，任务都是要被异步执行，所以提交任务的方法都是异步的。而对任务作出回应的方法很多分为两个版本，如
    1. 同步方法，如 thenRun(action), whenComplete(action)
    2. 异步方法，如 thenRunAsync(action[, executor]), whenCompleteAsync(action[, executor]), 异步方法可以传入线程池，否则用默认的

    因此所要理解的 CompletableFuture 的线程会涉及到任务与回调函数所使用的线程。 Read More

  • Java 8 CompletableFuture 浅入

    calendar Dec 23, 2016   ---   · 3 min read · java8 Future CompletableFuture CompletionStage  ·
    Share on: linkedin copy
    Java 8 CompletableFuture 浅入
    Java 1.5 有了 Future, 可谓是跨了一大步，继而 Java 1.8 新加入一个 Future 的实现 CompletableFuture, 从此线程与线程之间可以愉快的对话了。最初两个线程间的协调我采用过 Object 的  wait() 和 notify() , Thread 的 join() 方法，那可算是很低级的 API 了，是否很多 Java 程序都不知道它们的存在，或根本没用过它们。


    如果是简单的等待所有线程完成可使用 Java 1.5 的 CountDownLatch, 这里有一篇介绍 CountDownLatch 协调线程, 就是实现的 waitAll(threads) 功能。而 Java 8 的 CompletableFuture 的功能就多去，可简单使用它实现异步方法。虽说 CompletableFuture 实现了 Future 接口，但它多数方法源自于 CompletionStage, 所以还里氏代换，用 Future 来引用 CompletableFuture 实例就很牵强了; 这也是为什么 PlayFramework 自 2.5 开始直接暴露的类型是 CompletionStage 而非其他两个。

    顾名思义，CompletableFuture 代表着一个 Future 完成后该干点什么，具体大致有：

    1. Future 完成后执行动作，或求取下一个 Future 的值。then...
    2. 多个 Future 的协调; 同时完成该怎么，其中一个完成该如何。allOf, anyOf

    有时候可以把 Future 想像成与线程是一一对应的。 Read More

  • 巩固 Java Future 的使用

    calendar Dec 22, 2016   ---   · 2 min read · Future CompletableFuture  ·
    Share on: linkedin copy
    Future 还是一 Java 1.5 带进来的产物，但过去那么多年实际代码中却很少有直接接触, 大约它多是隐匿在各种现成框架中默默的为我们服务。Future 本身不代表着多线程，而是代表着需异步计算的结果, 将来的一个期待，至于后来真正的结果不可知。在此之前想要获得一个 Runnable 在其他线程中的计算结果颇费波折，有了 Future 加之它身后的 Callable 一切就变得简单了。


    对比一下 Java 1.5 前后的下面几个概念

    1. Callable 相当于之前的 Runnable, 只是 Callable 是有返回值的
    2. ExecuteService.submit(callable): Future 就类似于之前的 Thread(runnable)
      只是前者 submit 后立即执行，通过 get() 获得结果，后者用 start() 方法启动，runnable 是没有结果的。如果你也不想关心 Future 的结果也能 ExecuteService.submit(runnable)

    只有 callable 被提交(到线程池) 后返回的 Future 才可能会有结果, 所以下面的代码永远等不到结果
    Future future = new FutureTask<>(() -> "Never");
    String result = future.get();

    最容易理解的 Future 基本使用代码如下： Read More