change: disable spinwait

ishland · ishland · commit fb39f51c3bc9 · 2024-11-29T18:11:33.000+08:00
Cherry-picked from d32f47f, 41f4462
diff --git a/FlowSched b/FlowSched
@@ -1 +1 @@
-Subproject commit ac9b2349820cfe0d8d51b8231d977a198f41c18b
+Subproject commit f5c2b67defa7348ffdbc44ccbde040346b3fa437
diff --git a/c2me-base/src/main/java/com/ishland/c2me/base/common/scheduler/SingleThreadExecutor.java b/c2me-base/src/main/java/com/ishland/c2me/base/common/scheduler/SingleThreadExecutor.java
@@ -28,14 +28,14 @@ public void run() {
                 return;
             }
 
-            // attempt to spin-wait before sleeping
-            if (!pollTasks()) {
-                Thread.interrupted(); // clear interrupt flag
-                for (int i = 0; i < 5000; i ++) {
-                    if (pollTasks()) continue main_loop;
-                    LockSupport.parkNanos("Spin-waiting for tasks", 10_000); // 100us
-                }
-            }
+//            // attempt to spin-wait before sleeping
+//            if (!pollTasks()) {
+//                Thread.interrupted(); // clear interrupt flag
+//                for (int i = 0; i < 5000; i ++) {
+//                    if (pollTasks()) continue main_loop;
+//                    LockSupport.parkNanos("Spin-waiting for tasks", 10_000); // 100us
+//                }
+//            }
 
             synchronized (sync) {
                 if (this.size.get() != 0 || this.shutdown.get()) continue main_loop;
diff --git a/c2me-rewrites-chunkio/src/main/java/com/ishland/c2me/rewrites/chunkio/common/C2MEStorageThread.java b/c2me-rewrites-chunkio/src/main/java/com/ishland/c2me/rewrites/chunkio/common/C2MEStorageThread.java
@@ -93,14 +93,14 @@ public void run() {
                     this.closeFuture.complete(null);
                     break;
                 } else {
-                    // attempt to spin-wait before sleeping
-                    if (!pollTasks()) {
-                        Thread.interrupted(); // clear interrupt flag
-                        for (int i = 0; i < 5000; i ++) {
-                            if (pollTasks() || this.closing.get()) continue main_loop;
-                            LockSupport.parkNanos("Spin-waiting for tasks", 10_000); // 100us
-                        }
-                    }
+//                    // attempt to spin-wait before sleeping
+//                    if (!pollTasks()) {
+//                        Thread.interrupted(); // clear interrupt flag
+//                        for (int i = 0; i < 5000; i ++) {
+//                            if (pollTasks() || this.closing.get()) continue main_loop;
+//                            LockSupport.parkNanos("Spin-waiting for tasks", 10_000); // 100us
+//                        }
+//                    }
                     synchronized (sync) {
                         if (this.taskSize.get() != 0 || this.closing.get()) continue main_loop;
                         try {
