SelectState: Instantiate the FiberBlocker in the caller

Remove dependency on the global state.
Geod24 · Mar 4, 2021 · e0b3c02 · e0b3c02
1 parent ab5c6fb
commit e0b3c02
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/source/geod24/concurrency.d b/source/geod24/concurrency.d
@@ -728,7 +728,7 @@ public SelectReturn select (ref SelectEntry[] read_list, ref SelectEntry[] write
 {
     import std.random : randomShuffle;
 
-    auto ss = new SelectState();
+    auto ss = new SelectState(thisScheduler().new FiberBlocker());
     int sel_id = 0;
     thisScheduler().addResource(ss);
     scope (exit) thisScheduler().removeResource(ss);
@@ -775,9 +775,9 @@ final private class SelectState : FiberScheduler.Resource
 
     ***********************************************************************/
 
-    this () nothrow
+    this (FiberScheduler.FiberBlocker blocker) @safe pure nothrow @nogc
     {
-        this.blocker = thisScheduler().new FiberBlocker();
+        this.blocker = blocker;
     }
 
     /***********************************************************************