Pass :hint-affinity to scheduler in some places

These are cases where the input is arriving to be emitted by a Supply, and thus having multiple threads scrambling to handle the input will do more harm than good. Ignored by the current thread pool scheduler, but will be used by the upcoming new one.
rakudo · Sep 13, 2017 · d2eb742 · d2eb742
1 parent 760530a
commit d2eb742
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 5 deletions.
diff --git a/src/core/IO/Notification.pm b/src/core/IO/Notification.pm
@@ -19,7 +19,7 @@ my class IO::Notification {
         my $is-dir = $path.IO.d;
         my $s = Supplier.new;
         nqp::watchfile(
-            $scheduler.queue,
+            $scheduler.queue(:hint-affinity),
             -> \path, \rename, \err {
                 if err {
                     $s.quit(err);

diff --git a/src/core/IO/Socket/Async.pm b/src/core/IO/Socket/Async.pm
@@ -55,7 +55,8 @@ my class IO::Socket::Async {
             my $cancellation;
             Supply.on-demand:
                 -> $supply {
-                    $cancellation := nqp::asyncreadbytes($!VMIO, $scheduler.queue,
+                    $cancellation := nqp::asyncreadbytes($!VMIO,
+                        $scheduler.queue(:hint-affinity),
                         capture($supply), nqp::decont($buf), SocketCancellation);
                     $!close-promise.then({ $supply.done });
                 },
@@ -119,7 +120,7 @@ my class IO::Socket::Async {
         my $encoding = Encoding::Registry.find($enc);
         Supply.on-demand(-> $s {
             $cancellation := nqp::asynclisten(
-                $scheduler.queue,
+                $scheduler.queue(:hint-affinity),
                 -> Mu \socket, Mu \err, Mu \peer-host, Mu \peer-port, Mu \socket-host, Mu \socket-port {
                     if err {
                         $s.quit(err);
@@ -189,7 +190,7 @@ my class IO::Socket::Async {
         my $p = Promise.new;
         my $encoding = Encoding::Registry.find($enc);
         nqp::asyncudp(
-            $scheduler.queue,
+            $scheduler.queue(:hint-affinity),
             -> Mu \socket, Mu \err {
                 if err {
                     $p.break(err);

diff --git a/src/core/Proc/Async.pm b/src/core/Proc/Async.pm
@@ -337,7 +337,7 @@ my class Proc::Async {
         nqp::bindkey($callbacks, 'stdout_fd', $!stdout-fd) if $!stdout-fd.DEFINITE;
         nqp::bindkey($callbacks, 'stderr_fd', $!stderr-fd) if $!stderr-fd.DEFINITE;
 
-        $!process_handle := nqp::spawnprocasync($scheduler.queue,
+        $!process_handle := nqp::spawnprocasync($scheduler.queue(:hint-affinity),
             CLONE-LIST-DECONTAINERIZED($!path,@!args),
             $cwd.Str,
             CLONE-HASH-DECONTAINERIZED(%ENV),