文章详情

短信预约-IT技能 免费直播动态提醒

请输入下面的图形验证码

提交验证

短信预约提醒成功

Java协程编程之Loom

2024-04-02 19:55

关注

Java协程编程Loom

前提:

OpenJDK给出的官网https://openjdk.java.net/projects/loom有少量Loom项目相关的信息)JDK17编译和JDK18编译等早期版本,Loom早期版本JDK18编译的版本:下载入口在:https://jdk.java.net/loom

由于该JDK版本过高,目前可以使用主流IDE导入Loom-JDK-18+9进行代码高亮和语法提醒,暂时找不到方法进行编译,暂时使用该JDK执行目录下的的javac命令脚本进行编译,使用java命令脚本运行。

1、Loom项目简单介绍


Loom - Fibers, Continuations and Tail-Calls for the JVM

Loom项目的已经凸显了引入的三大新特性:

三个新特性不详细展开,目前只是EA版本,还存在修改的可能性,所以也没必要详细展开。

2、Virtual Thread使用

当前版本Loom项目中协程使用并没有引入一个新的公开的虚拟线程VirtualThread类,虽然真的存在VirtualThread,但这个类使用default修饰符,隐藏在java.lang包中,并且VirtualThreadThread的子类。协程的创建API位于Thread类中:

使用此API创建协程如下:


public static void main(String[] args) {
    Thread fiber = Thread.startVirtualThread(() -> System.out.println("Hello Fiber"));
}

从当前的源码可知:

如果按照上面的Thread.startVirtualThread()方法去创建协程,显然无法定义协程的名称等属性。Loom项目为Thread类引入了建造者模式,比较合理地解决了这个问题:


// 创建平台线程建造器,对应于Thread实例
public static Builder.OfPlatform ofPlatform() {
    return new ThreadBuilders.PlatformThreadBuilder();
}

// 创建虚拟线程建造器,对应于VirtualThread
public static Builder.OfVirtual ofVirtual() {
    return new ThreadBuilders.VirtualThreadBuilder();
}

简单说就是:

ofPlatform()方法用于构建Thread实例,这里的Platform Thread(平台线程)其实就是JDK1.0引入的线程实例,普通的用户线程
ofVirtual()方法用于构建VirtualThread实例,也就是构建协程实例

这两个建造器实例的所有Setter方法链展开如下:


public static void main(String[] args) {
    Thread.Builder.OfPlatform platformThreadBuilder = Thread.ofPlatform()
            // 是否守护线程
            .daemon(true)
            // 线程组
            .group(Thread.currentThread().getThreadGroup())
            // 线程名称
            .name("thread-1")
            // 线程名称前缀 + 起始自增数字 => prefix + start,下一个创建的线程名称就是prefix + (start + 1)
            // start > 0的情况下会覆盖name属性配置
            .name("thread-", 1L)
            // 是否启用ThreadLocal
            .allowSetThreadLocals(false)
            // 是否启用InheritableThreadLocal
            .inheritInheritableThreadLocals(false)
            // 设置优先级
            .priority(100)
            // 设置线程栈深度
            .stackSize(10)
            // 设置未捕获异常处理器
            .uncaughtExceptionHandler(new Thread.UncaughtExceptionHandler() {
                @Override
                public void uncaughtException(Thread t, Throwable e) {

                }
            });
    // thread-1
    Thread firstThread = platformThreadBuilder.unstarted(() -> System.out.println("Hello Platform Thread First"));
    // thread-2
    Thread secondThread = platformThreadBuilder.unstarted(() -> System.out.println("Hello Platform Thread Second"));
    Thread.Builder.OfVirtual virtualThreadBuilder = Thread.ofVirtual()
            // 协程名称
            .name("fiber-1")
            // 协程名称前缀 + 起始自增数字 => prefix + start,下一个创建的协程名称就是prefix + (start + 1)
            // start > 0的情况下会覆盖name属性配置
            .name("fiber-", 1L)
            // 是否启用ThreadLocal
            .allowSetThreadLocals(false)
            // 是否启用InheritableThreadLocal
            .inheritInheritableThreadLocals(false)
            // 设置调度器,Executor实例,也就是调度器是一个线程池,设置为NULL会使用VirtualThread.DEFAULT_SCHEDULER
            .scheduler(null)
            // 设置未捕获异常处理器
            .uncaughtExceptionHandler(new Thread.UncaughtExceptionHandler() {
                @Override
                public void uncaughtException(Thread t, Throwable e) {

                }
            });
    // fiber-1
    Thread firstFiber = virtualThreadBuilder.unstarted(() -> System.out.println("Hello Platform Virtual First"));
    // fiber-2
    Thread secondFiber = virtualThreadBuilder.unstarted(() -> System.out.println("Hello Platform Virtual Second"));
}

这里可以发现一点,就是建造器是可以复用的。如果想用建造器创建同一批参数设置相同的线程或者协程,可以设置name(String prefix, long start)方法,定义线程或者协程的名称前缀和一个大于等于0的数字,反复调用Builder#unstarted(Runnable task)方法就能批量创建线程或者协程,名称就设置为prefix + start、prefix + (start + 1)、prefix + (start + 2)以此类推。协程创建基本就是这么简单,运行的话直接调用start()方法:


public class FiberSample2 {

    public static void main(String[] args) throws Exception {
        Thread.ofVirtual()
                .name("fiber-1")
                .allowSetThreadLocals(false)
                .inheritInheritableThreadLocals(false)
                .unstarted(() -> {
                    Thread fiber = Thread.currentThread();
                    System.out.printf("[%s,daemon:%s,virtual:%s] - Hello World\n", fiber.getName(),
                            fiber.isDaemon(), fiber.isVirtual());
                }).start();
        // 主线程休眠
        Thread.sleep(Long.MAX_VALUE);
    }
}

目前无法在主流IDE编译上面的类,所以只能使用该JDK目录下的工具编译和运行,具体如下:


# 执行 - 当前目录I:\J-Projects\framework-source-code\fiber-sample\src\main\java
(1)编译:I:\Environment\Java\jdk-18-loom\bin\javac.exe I:\J-Projects\framework-source-code\fiber-sample\src\main\java\cn\throwx\fiber\sample\FiberSample2.java
(2)执行main方法:I:\Environment\Java\jdk-18-loom\bin\java.exe  cn.throwx.fiber.sample.FiberSample2

这里也看出了一点,所有的协程实例的daemon标识默认为true且不能修改

以上就是Java协程编程之Loom的详细内容,更多关于Java编程Loom的资料请关注编程网其它相关文章!

阅读原文内容投诉

免责声明:

① 本站未注明“稿件来源”的信息均来自网络整理。其文字、图片和音视频稿件的所属权归原作者所有。本站收集整理出于非商业性的教育和科研之目的,并不意味着本站赞同其观点或证实其内容的真实性。仅作为临时的测试数据,供内部测试之用。本站并未授权任何人以任何方式主动获取本站任何信息。

② 本站未注明“稿件来源”的临时测试数据将在测试完成后最终做删除处理。有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341

软考中级精品资料免费领

  • 历年真题答案解析
  • 备考技巧名师总结
  • 高频考点精准押题
  • 2024年上半年信息系统项目管理师第二批次真题及答案解析(完整版)

    难度     813人已做
    查看
  • 【考后总结】2024年5月26日信息系统项目管理师第2批次考情分析

    难度     354人已做
    查看
  • 【考后总结】2024年5月25日信息系统项目管理师第1批次考情分析

    难度     318人已做
    查看
  • 2024年上半年软考高项第一、二批次真题考点汇总(完整版)

    难度     435人已做
    查看
  • 2024年上半年系统架构设计师考试综合知识真题

    难度     224人已做
    查看

相关文章

发现更多好内容

猜你喜欢

AI推送时光机
位置:首页-资讯-后端开发
咦!没有更多了?去看看其它编程学习网 内容吧
首页课程
资料下载
问答资讯