diff options
| author | Eduardo Julian | 2018-07-31 20:22:15 -0400 |
|---|---|---|
| committer | Eduardo Julian | 2018-07-31 20:22:15 -0400 |
| commit | 7e44ee8a2cfb14e35f6283a9eb8d6a2ddc8bd99a (patch) | |
| tree | 98a12aa5a9fd347c1070612a2a1dae69dae879b1 /stdlib/test | |
| parent | eea58ee669f69fddf2cef9e1675c41959e2e0a55 (diff) | |
Now implementing process functionality in stdlib instead of the compiler.
Diffstat (limited to 'stdlib/test')
| -rw-r--r-- | stdlib/test/test/lux/compiler/default/phase/analysis/procedure/common.lux | 15 | ||||
| -rw-r--r-- | stdlib/test/test/lux/concurrency/stm.lux | 5 |
2 files changed, 3 insertions, 17 deletions
diff --git a/stdlib/test/test/lux/compiler/default/phase/analysis/procedure/common.lux b/stdlib/test/test/lux/compiler/default/phase/analysis/procedure/common.lux index 8d3e8b8fa..9d733912e 100644 --- a/stdlib/test/test/lux/compiler/default/phase/analysis/procedure/common.lux +++ b/stdlib/test/test/lux/compiler/default/phase/analysis/procedure/common.lux @@ -245,21 +245,6 @@ #0))) )))) -(context: "Process procedures" - (<| (times 100) - (do @ - [[primT primC] _primitive.primitive - timeC (|> r.nat (:: @ map code.nat))] - ($_ seq - (test "Can query the level of concurrency." - (check-success+ "lux process parallelism-level" (list) Nat)) - (test "Can schedule an IO computation to run concurrently at some future time." - (check-success+ "lux process schedule" - (list timeC - (` ([(~' _) (~' _)] (~ primC)))) - Any)) - )))) - (context: "IO procedures" (<| (times 100) (do @ diff --git a/stdlib/test/test/lux/concurrency/stm.lux b/stdlib/test/test/lux/concurrency/stm.lux index 3506146f4..ee84f193e 100644 --- a/stdlib/test/test/lux/concurrency/stm.lux +++ b/stdlib/test/test/lux/concurrency/stm.lux @@ -10,6 +10,7 @@ [concurrency ["." atom (#+ Atom atom)] ["&" stm] + ["." process] ["." promise] ["." frp (#+ Channel)]] [math @@ -62,7 +63,7 @@ (list.reverse changes))))) (wrap (let [_concurrency-var (&.var 0)] (do promise.Monad<Promise> - [_ (|> promise.parallelism + [_ (|> process.parallelism (list.n/range 1) (list/map (function (_ _) (|> iterations-per-process @@ -71,6 +72,6 @@ (M.seq @)) last-val (&.commit (&.read _concurrency-var))] (assert "Can modify STM vars concurrently from multiple threads." - (|> promise.parallelism + (|> process.parallelism (n/* iterations-per-process) (n/= last-val)))))))) |