同步操作将从 dwing/sharecode 强制同步,此操作会覆盖自 Fork 仓库以来所做的任何修改,且无法恢复!!!
确定后同步将在后台操作,完成时将刷新页面,请耐心等待。
import java.util.concurrent.Executor;import java.util.concurrent.locks.LockSupport;import sun.misc.Unsafe;// java Loompublic class Loom {public static void main(String[] args) throws Exception {var f = Unsafe.class.getDeclaredField("theUnsafe");f.setAccessible(true);var U = (Unsafe)f.get(null);long OVERRIDE_OFFSET;for (long i = 0; ; ) {if (U.getBoolean(f, i)) {f.setAccessible(false);if (!U.getBoolean(f, i)) {OVERRIDE_OFFSET = i;break;}f.setAccessible(true);}if (++i == 32) // should be enoughthrow new UnsupportedOperationException();}var tb = Thread.ofVirtual();f = tb.getClass().getDeclaredField("scheduler");U.putBoolean(f, OVERRIDE_OFFSET, true); // f.setAccessible(true);f.set(tb, (Executor)Runnable::run);var t = new Thread[2];t[0] = tb.unstarted(() -> {System.out.println("t[0]: begin " + Thread.currentThread()); // 2LockSupport.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()); // 4LockSupport.park();LockSupport.unpark(t[0]);System.out.println("t[1]: end " + Thread.currentThread()); // 6});System.out.println("main: begin " + Thread.currentThread()); // 1t[0].start();System.out.println("main: ts[0] started"); // 3t[1].start();System.out.println("main: ts[1] started"); // 7t[0].join();System.out.println("main: end " + Thread.currentThread()); // 8}}
此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。