Ensure there's a thread for timer events.

Also, a minor simplification.
rakudo · Apr 19, 2014 · f7dcaa7 · f7dcaa7
1 parent 3814ab3
commit f7dcaa7
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/src/core/ThreadPoolScheduler.pm b/src/core/ThreadPoolScheduler.pm
@@ -67,21 +67,23 @@ my class ThreadPoolScheduler does Scheduler {
             nqp::timer($!queue,
                 &catch
                   ?? -> { code(); CATCH { default { catch($_) } } }
-                  !! -> { code() },
+                  !! &code,
                 ($delay * 1000).Int, ($every * 1000).Int,
                 AsyncCancellation);
+            self!maybe_new_thread() if !$!started_any
         }
 
         # only after waiting a bit or more than once
         elsif $delay or $times > 1 {
             my $todo := &catch
                 ?? -> { code(); CATCH { default { catch($_) } } }
-                !! -> { code() };
+                !! &code;
             for 1 .. $times {
                 nqp::timer($!queue, $todo, ($delay * 1000).Int, 0,
                     AsyncCancellation);
                 $delay = 0;
             }
+            self!maybe_new_thread() if !$!started_any
         }
 
         # just cue the code