diff options
Diffstat (limited to 'stdlib/source/lux/concurrency/process.lux')
| -rw-r--r-- | stdlib/source/lux/concurrency/process.lux | 11 |
1 files changed, 5 insertions, 6 deletions
diff --git a/stdlib/source/lux/concurrency/process.lux b/stdlib/source/lux/concurrency/process.lux index 2ff56c395..8cb364380 100644 --- a/stdlib/source/lux/concurrency/process.lux +++ b/stdlib/source/lux/concurrency/process.lux @@ -43,14 +43,14 @@ (def: #export parallelism Nat (`` (for {(~~ (static host.jvm)) - (|> (Runtime::getRuntime []) - (Runtime::availableProcessors []) + (|> (Runtime::getRuntime) + (Runtime::availableProcessors) .nat)} 1))) (def: runner (`` (for {(~~ (static host.jvm)) - (ScheduledThreadPoolExecutor::new [(.int ..parallelism)])} + (ScheduledThreadPoolExecutor::new (.int ..parallelism))} (: (Atom (List Process)) (atom.atom (list)))))) @@ -63,9 +63,8 @@ (Runnable [] (run) void (io.run action)))] (case milli-seconds - 0 (Executor::execute [runnable] - runner) - _ (ScheduledThreadPoolExecutor::schedule [runnable (.int milli-seconds) TimeUnit::MILLISECONDS] + 0 (Executor::execute runnable runner) + _ (ScheduledThreadPoolExecutor::schedule runnable (.int milli-seconds) TimeUnit::MILLISECONDS runner)))} (atom.update (|>> (#.Cons {#creation ("lux io current-time") #delay milli-seconds |