• 使用 Google Guava Striped 实现基于 Key 的并发锁

    calendar Jun 2, 2019   ---   · 4 min read · Concurreent Striped  ·
    Share on: linkedin copy
    写 Java 代码至今，在应对可能冲突的共享资源操作时会尽量用 JDK 1.5 开始引入的并发锁(如 Lock 的各类实现类, ReentrantLock 等) 进行锁定，而不是原来的 synchronized 关键字强硬低性能锁。

    这里是应用 JDK 1.5  的 Lock 的基本操作步骤
    private Lock lock = new ReentrantLock(); private void operate() {
        // 安全操作 ....
        lock.lock();
        try {
            // 对共享资源的操作 ...
        } finally {
            lock.unlock();
        }
    }
    如此，operate() 就是一个线程安全的方法，任何对它的调用都安排到了一个队列里等着。但有时候上锁需要考虑更细的粒度，下面是一个演示案例，引出第一个问题
    Read More

  • 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