change: disable spinwait

RelativityMC · Nov 29, 2024 · 491bc6a · 491bc6a
1 parent 77c965b
commit 491bc6a
Show file tree

Hide file tree

Showing 2 changed files with 16 additions and 16 deletions.
diff --git a/src/main/java/com/ishland/flowsched/executor/WorkerThread.java b/src/main/java/com/ishland/flowsched/executor/WorkerThread.java
@@ -28,14 +28,14 @@ public void run() {
                 continue;
             }
 
-            // attempt to spin-wait before sleeping
-            if (!pollTasks()) {
-                Thread.interrupted(); // clear interrupt flag
-                for (int i = 0; i < 1000; i ++) {
-                    if (pollTasks()) continue main_loop;
-                    LockSupport.parkNanos("Spin-waiting for tasks", 10_000); // 10us
-                }
-            }
+//            // attempt to spin-wait before sleeping
+//            if (!pollTasks()) {
+//                Thread.interrupted(); // clear interrupt flag
+//                for (int i = 0; i < 1000; i ++) {
+//                    if (pollTasks()) continue main_loop;
+//                    LockSupport.parkNanos("Spin-waiting for tasks", 10_000); // 10us
+//                }
+//            }
 
 //            LockSupport.parkNanos("Waiting for tasks", 1_000_000); // 1ms
             synchronized (this.executorManager.workerMonitor) {

diff --git a/src/main/java/com/ishland/flowsched/scheduler/DaemonizedStatusAdvancingScheduler.java b/src/main/java/com/ishland/flowsched/scheduler/DaemonizedStatusAdvancingScheduler.java
@@ -47,14 +47,14 @@ private void mainLoop() {
                 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
+//                }
+//            }
 
 //            LockSupport.parkNanos("Waiting for tasks", 1_000_000); // 1ms
             synchronized (this.notifyMonitor) {