diff options
Diffstat (limited to 'stdlib/source/test/lux/control/concurrency/semaphore.lux')
| -rw-r--r-- | stdlib/source/test/lux/control/concurrency/semaphore.lux | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/stdlib/source/test/lux/control/concurrency/semaphore.lux b/stdlib/source/test/lux/control/concurrency/semaphore.lux index 54143c345..c14ddba68 100644 --- a/stdlib/source/test/lux/control/concurrency/semaphore.lux +++ b/stdlib/source/test/lux/control/concurrency/semaphore.lux @@ -41,7 +41,7 @@ (_.for [/.Semaphore] (all _.and (do [! random.monad] - [initial_open_positions (|> random.nat (at ! each (|>> (n.% 10) (n.max 1)))) + [initial_open_positions (|> random.nat (of ! each (|>> (n.% 10) (n.max 1)))) .let [semaphore (/.semaphore initial_open_positions)]] (in (do async.monad [result (async.within ..delay (/.wait! semaphore))] @@ -53,7 +53,7 @@ {.#None} false))))) (do [! random.monad] - [initial_open_positions (|> random.nat (at ! each (|>> (n.% 10) (n.max 1)))) + [initial_open_positions (|> random.nat (of ! each (|>> (n.% 10) (n.max 1)))) .let [semaphore (/.semaphore initial_open_positions)]] (in (do [! async.monad] [_ (monad.each ! /.wait! (list.repeated initial_open_positions semaphore)) @@ -66,7 +66,7 @@ {.#None} true))))) (do [! random.monad] - [initial_open_positions (|> random.nat (at ! each (|>> (n.% 10) (n.max 1)))) + [initial_open_positions (|> random.nat (of ! each (|>> (n.% 10) (n.max 1)))) .let [semaphore (/.semaphore initial_open_positions)]] (in (do [! async.monad] [_ (monad.each ! /.wait! (list.repeated initial_open_positions semaphore)) @@ -82,7 +82,7 @@ _ false))))) (do [! random.monad] - [initial_open_positions (|> random.nat (at ! each (|>> (n.% 10) (n.max 1)))) + [initial_open_positions (|> random.nat (of ! each (|>> (n.% 10) (n.max 1)))) .let [semaphore (/.semaphore initial_open_positions)]] (in (do async.monad [outcome (/.signal! semaphore)] @@ -100,7 +100,7 @@ (_.for [/.Mutex] (all _.and (do [! random.monad] - [repetitions (|> random.nat (at ! each (|>> (n.% 100) (n.max 10)))) + [repetitions (|> random.nat (of ! each (|>> (n.% 100) (n.max 10)))) .let [resource (atom.atom "") expected_As (text.together (list.repeated repetitions "A")) expected_Bs (text.together (list.repeated repetitions "B")) @@ -157,7 +157,7 @@ _ false))) (do [! random.monad] - [limit (at ! each (|>> (n.% 9) ++) random.nat) + [limit (of ! each (|>> (n.% 9) ++) random.nat) .let [barrier (/.barrier (maybe.trusted (/.limit limit))) resource (atom.atom "")]] (in (do [! async.monad] |