java/src/Loom.java · 睿凡/sharecode

代码拉取完成,页面将自动刷新

扫描微信二维码支付

取消

支付完成

richgiteeai

Watch

不关注关注所有动态仅关注版本发行动态关注但不提醒动态

1 Star 0 Fork 3

睿凡/sharecode

forked from dwing/sharecode

代码 Issues 0 Pull Requests 0 Wiki 统计流水线

服务

加入 Gitee

与超过 1400万开发者一起发现、参与优秀开源项目,私有仓库也完全免费 :)

免费加入

已有帐号? 立即登录

文件

main

分支 (1)

管理

main

克隆/下载

HTTPS SSH SVN SVN+SSH 下载ZIP

提示

下载代码请复制以下命令到终端执行

为确保你提交的代码身份被 Gitee 正确识别,请执行以下命令完成配置

git config --global user.name userName 
git config --global user.email userEmail

初次使用 SSH 协议进行代码克隆、推送等操作时,需按下述提示完成 SSH 配置

1 生成 RSA 密钥

2 获取 RSA 公钥内容,并配置到 SSH公钥中

在 Gitee 上使用 SVN,请访问使用指南

使用 HTTPS 协议时,命令行会出现如下账号密码验证步骤。基于安全考虑,Gitee 建议配置并使用私人令牌替代登录密码进行克隆、推送等操作

Username for 'https://gitee.com': userName

Password for 'https://userName@gitee.com': # 私人令牌

分支 1

标签 0

sharecode

java

src

Loom.java

Loom.java 1.05 KB

import java.util.concurrent.Executor;
import java.util.concurrent.locks.LockSupport;
import util.UnsafeUtil;

// java Loom
public class Loom {
	public static void main(String[] args) throws Exception {
		var tb = Thread.ofVirtual();
		UnsafeUtil.getField(tb.getClass(), "scheduler").set(tb, (Executor)Runnable::run);

var t = new Thread[2];
		t[0] = tb.unstarted(() -> {
			System.out.println("t[0]: begin " + Thread.currentThread()); // 2
			LockSupport.unpark(t[1]);
			LockSupport.park();
			System.out.println("t[0]: end " + Thread.currentThread()); // 5
		});
		t[1] = tb.unstarted(() -> {
			System.out.println("t[1]: begin " + Thread.currentThread()); // 4
			LockSupport.park();
			LockSupport.unpark(t[0]);
			System.out.println("t[1]: end " + Thread.currentThread()); // 6
		});
		System.out.println("main: begin " + Thread.currentThread()); // 1
		t[0].start();
		System.out.println("main: ts[0] started"); // 3
		t[1].start();
		System.out.println("main: ts[1] started"); // 7
		t[0].join();
		System.out.println("main: end " + Thread.currentThread()); // 8
	}
}

一键复制编辑原始数据按行查看历史

dwing 提交于 2024年07月12日 17:41 +08:00 . java: move Unsafe calls to UnsafeUtil; fix warnings

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32

import java.util.concurrent.Executor;
import java.util.concurrent.locks.LockSupport;
import util.UnsafeUtil;

// java Loom
public class Loom {
	public static void main(String[] args) throws Exception {
		var tb = Thread.ofVirtual();
		UnsafeUtil.getField(tb.getClass(), "scheduler").set(tb, (Executor)Runnable::run);

		var t = new Thread[2];
		t[0] = tb.unstarted(() -> {
			System.out.println("t[0]: begin " + Thread.currentThread()); // 2
			LockSupport.unpark(t[1]);
			LockSupport.park();
			System.out.println("t[0]: end " + Thread.currentThread()); // 5
		});
		t[1] = tb.unstarted(() -> {
			System.out.println("t[1]: begin " + Thread.currentThread()); // 4
			LockSupport.park();
			LockSupport.unpark(t[0]);
			System.out.println("t[1]: end " + Thread.currentThread()); // 6
		});
		System.out.println("main: begin " + Thread.currentThread()); // 1
		t[0].start();
		System.out.println("main: ts[0] started"); // 3
		t[1].start();
		System.out.println("main: ts[1] started"); // 7
		t[0].join();
		System.out.println("main: end " + Thread.currentThread()); // 8
	}
}