One last place where we can use push-worker

rakudo · Nov 1, 2017 · b386963 · b386963
1 parent 5e158d9
commit b386963
Showing 1 changed file with 2 additions and 4 deletions.
diff --git a/src/core/ThreadPoolScheduler.pm b/src/core/ThreadPoolScheduler.pm
@@ -333,15 +333,13 @@ my class ThreadPoolScheduler does Scheduler {
                 unless $!general-queue.DEFINITE {
                     # We don't have any workers yet, so start one.
                     $!general-queue := nqp::create(Queue);
-                    my $workers := nqp::create(IterationBuffer);
-                    nqp::push(
-                      $workers,
+                    $!general-workers := push-worker(
+                      nqp::create(IterationBuffer),
                       GeneralWorker.new(
                         queue => $!general-queue,
                         scheduler => self
                       )
                     );
-                    $!general-workers := $workers;
                     scheduler-debug "Created initial general worker thread";
                     self!maybe-start-supervisor();
                 }