• Java 21 之虚拟线程深入学习及应用场景

    calendar Dec 25, 2025   ---   · 13 min read · virtual threads thread java 21  ·
    Share on: linkedin copy
    Java 21 之虚拟线程深入学习及应用场景

    篇首说明: 本文十分冗长, 语言组织混乱, 如果觉得 TLDR, 就直接跳到 关于虚拟线程的总结 部分看要点, 若对总结上中的某些要素点仍有兴趣的话请倒查本文中其他部分的内容. 个人对 Java 虚拟线程的主动研究是为了在项目中更有效的使用它.

    关于线程的概要

    Java 21 于两年前 2023 年 9 月份放出，它是一个 LTS(long term support) 版本，个人基本就是把 LTS 当作能在正式项目中使用的版本。 Java 21 有几个增进编程体验的特性，像 Sequenced Collections, Record Patterns, 和 Pattern Matching for switch, 而对于性能改进的， 也是 Java 21 最具代表的特性无疑就是 Virtual Threads -- 虚拟线程。本文单列出它来，着重感受一下虚拟线程是什么，以及我们应该如何使用它。

    其实在之前的 Java 19, 20 新特性学习 就有一定的笔墨介绍了于 Java 19 引入， Java 20 中尚处于第二次预览的虚拟线程。于其中大致体验了在一台 36 G 物理内存，默认堆内存为 9 G 的情况下， 创建 9000 个线程没问题，但要创建 10000 个线程就 OutOfMemoryError 了。而相同的环境下创建一百万个虚拟线程都没问题，没在继续往下试探了。

    其实这种比较是没有意义的, Java 线程对应到平台线程的, 每个线程要至少实实在在的 2M 栈空间, 而一百万个虚拟线程相当于是创建了一百万个 Java 对象而已, 更像是相应数量的 Task, 实际运行时才由载体线程去调度执行 - (注: 后面所提到的载体线程和平台线程是同一个概念).

    重新回顾一下何谓虚拟线程，Java 的虚拟线程实现是来自于 Project Loom 项目。与此相关的概念有线程，协程，以及纤程(Fiber)，而虚拟线程对应的应该是纤程。

    1. 线程是操作系统最小的调度单位，每个线程有独立较大的栈空间(比如 2M)，内核调度，切换开销大，可有效使用 CPU 多核
    2. 协程在单个线程内执行，共享线程栈空间或独立小空间，用户态调度，切换开销极小，但无法使用多核
    3. 纤程，介于线程与协程之间，很小的独立栈，用户态调度，切换开销较小。结合线程池，纤程可在线程间转移，这时岂不是要经内核态调度吗？
    Read More

  • 远程方式执行 JMeter 测试

    calendar Feb 18, 2023   ---   · 7 min read · Rmi Thread  ·
    Share on: linkedin copy
    远程方式执行 JMeter 测试
    JMeter 是一个极好的测试 Web API 及压力测试的工具，另一个的话就是 Python 版的 LOCUST(它也能远程运行测试)。JMeter 的测试可以在本地模拟并发用户，那么为什么要远程执行 JMeter 测试呢？因为一台机器能模拟的并发用户数受限，一个用户就是对应着一个 Java 线程。比如我在 MacBook Pro(内存 16Gb) 上无论如何调整 ulimit -n, ulimit -u, 或用 JAVA_TOOL_OPTIONS, HEAP, JVM_ARGS 设置 -Xmx, 调大到 10 G, 或用 -Xss 调小栈大小，都无法让 JMeter 模拟的用户数达到 5000。

    文后有本人亲自测试 Java/Python 在 Mac OS X 和 Linux 下可创建多少个线程

    如果能够远程运行 JMeter 的测试就能突破单机上的线程限制了，比如 Mac OS X 不行，找个 Linux 远程机器(可以是虚拟机)来执行，一台机器不够，找多个。想要模拟 15000 个并发用户，测试可分配到 5 台机器上执行，每个节点跑 3000 个用户并发就行，有点操控肉机的感觉。 Read More

  • Akka Actor: 从最简单的例子开始

    calendar Feb 11, 2018   ---   · 2 min read · Thread concurrent actor  ·
    Share on: linkedin copy
    Akka Actor: 从最简单的例子开始
    Akka 是什么？它提供了 JVM 上的 Actor 编程模型 -- 同时兼顾了并发与分布式。它由 Scala 编写的，替代了 Scala 本身的 Actor。Actor 视线程为重量级的资源，能够以少量的内存胜任更高的并发，类似的东西有纤程，协程。有一个数据对比是同样的 1GB 内存，可以创建 2.7M 个 Actor, 而线程只能创建 4096 个，仅供参考，当然 Java 也是会基于线程池来执行的。

    Actor 增加了程序的灵活性，并减轻了复杂度(标准的赞美之辞)。

    所谓 Action 编程模型兼顾并发与分布，是由于让你编程时可以不用考虑线程，线程配置成为部署的范畴; Actor 之间通信只能发送异步消息，Actor 可以分布在同一 JVM, 不同 JVM, 或是不同物理机器上。

    因为 《Akka IN ACTION》中提供了第一个例子起点着实有点高，所以网上找来了一个了解 Akka Actor 的最简单例子，来自于 Simple Scala Akka Actor examples (Hello, world examples)。并非纯属翻译，主要是为了练手，所以不完全一致： Read More

  • Java8 Lambda 表达式与 Checked Exception

    calendar Feb 8, 2017   ---   · 2 min read · Thread lambda java8  ·
    Share on: linkedin copy
    Java8 Lambda 表达式与 Checked Exception
    当我们在使用 Java 8 的 Lambda 表达式时，表达式内容需要抛出异常，也许还会想当然的让当前方法再往外抛来解决编译问题，如下面的代码
    让 main() 方法抛出 Exception 还是不解决决编译错误，仍然提示 "Unhandled exception: java.io.FileNotFoundException"。

    因为我们可能保持着惯性思维，忽略了 Lambda 本身就是一个功能性接口方法的实现，所以把上面的代码还原为匿名类的方式
    1public void foo() {
2    Stream.of("a", "b").forEach(new Consumer<String>() {
3        @Override
4        public void accept(String s) {
5            new FileInputStream(s).close();
6        }
7});

    那么对于上面那种情况应该如何处理呢？ Read More

  • 使用 JDK 5 后的线程并发，Callable, Future, ExecutorServie ...

    calendar Apr 10, 2013   ---   · 2 min read · multithread Thread JDK5  ·
    Share on: linkedin copy
    被问及 Java 多线程，多会想到 Thread, Runnable，更通常是用 new Thread(){public void run(){...}}.start() 来启动一个线程。那都是 JDK 1.5 之前的年代了，现在还这么回答就 Out 了。用用  JDK 1.5 给我们带来的  java.util.concurrent 吧，更酷了。这里不涉及它的并发集合类，同步互斥机制，只说线程及线程池的应用举例。


    1. 新的启动线程的方式：
     1public static void main(String[] args) throws Exception {
 2    Callable<Integer> callable = new Callable<Integer>() {
 3        public Integer call() throws Exception {
 4            System.out.println("callable executed.");
 5            return new Random().nextInt(100);
 6        }
 7    };
 8    
 9    FutureTask<Integer> future = new FutureTask<Integer>(callable);
10    new Thread(future).start();
11    
12    System.out.println("do your things here");
13    
14    System.out.println(future.get());
15}
    Read More