WIP

softwaremill · Oct 31, 2023 · 8f006a5 · 8f006a5
1 parent 218162c
commit 8f006a5
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 5 deletions.
diff --git a/core/src/main/scala/ox/channels2/Channel.scala b/core/src/main/scala/ox/channels2/Channel.scala
@@ -23,11 +23,11 @@ class Channel[T]:
       result
 
     def await(onInterrupt: () => Unit): E =
-      var firstIteration = true
+      var spinIterations = 1000
       while data.get() == null do
-        if firstIteration then
-          Thread.`yield`()
-          firstIteration = false
+        if spinIterations > 0 then
+          Thread.onSpinWait()
+          spinIterations -= 1
         else LockSupport.park()
 
         if Thread.interrupted() then

diff --git a/core/src/main/scala/ox/channels2/perf/tests.scala b/core/src/main/scala/ox/channels2/perf/tests.scala
@@ -1,7 +1,7 @@
 package ox.channels2.perf
 
 @main def run(): Unit =
-  for (i <- 1 to 3) {
+  for (i <- 1 to 10) {
     println(s"Run $i")
     usingOx()
 //    passingValues()