同步操作将从 dwing/sharecode 强制同步,此操作会覆盖自 Fork 仓库以来所做的任何修改,且无法恢复!!!
确定后同步将在后台操作,完成时将刷新页面,请耐心等待。
import java.util.ArrayDeque;import java.util.ArrayList;import java.util.Deque;import jdk.internal.vm.Continuation;import jdk.internal.vm.ContinuationScope;// java --enable-preview --add-opens java.base/jdk.internal.vm=ALL-UNNAMED Prime2public class Prime2 {static final ContinuationScope cs = new ContinuationScope("");static final ArrayList<Continuation> readyStack = new ArrayList<>(10000);static void loop() {for (int n; (n = readyStack.size()) > 0; )readyStack.remove(n - 1).run();}static void resume(Continuation c) {readyStack.add(c);}static void go(Runnable r) {new Continuation(cs, r).run();}static void pause(Deque<Continuation> queue) {queue.addLast(Continuation.getCurrentContinuation(cs));Continuation.yield(cs);}static class IntChan {private final ArrayDeque<Continuation> waitQueue = new ArrayDeque<>();private int value;private boolean hasValue;void put(int v) {if (hasValue)pause(waitQueue);value = v;hasValue = true;var c = waitQueue.pollFirst();if (c != null)resume(c);}int get() {if (!hasValue)pause(waitQueue);hasValue = false;var c = waitQueue.pollFirst();if (c != null)resume(c);return value;}}static void generate(IntChan ch) {//noinspection InfiniteLoopStatementfor (int i = 2; ; i++)ch.put(i);}static void filter(IntChan in, IntChan out, int prime) {//noinspection InfiniteLoopStatementfor (; ; ) {var i = in.get();if (i % prime != 0)out.put(i);}}public static void main(String[] args) {var count = args.length > 0 ? Integer.parseInt(args[0]) : 10000;var ch = new IntChan();go(() -> generate(ch));go(() -> {var ch0 = ch;for (int i = 0; ; ) {var prime = ch0.get();if (++i == count) {System.out.println(prime);System.exit(0);}var ch1 = ch0;var ch2 = new IntChan();go(() -> filter(ch1, ch2, prime));ch0 = ch2;}});loop();}}
此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。