diff options
| author | Eduardo Julian | 2021-08-14 03:09:58 -0400 |
|---|---|---|
| committer | Eduardo Julian | 2021-08-14 03:09:58 -0400 |
| commit | 6fd22846f21b8b70b7867e989109d14a366c0a3e (patch) | |
| tree | 9086774968ad944133dc5cf29c546add6e13a4b6 /stdlib/source/library/lux/control/concurrency/semaphore.lux | |
| parent | e53c1a090eb9cfac3cb23d10d981648d02518ed1 (diff) | |
Moved documentation-generation machinery to its own module.
Diffstat (limited to '')
| -rw-r--r-- | stdlib/source/library/lux/control/concurrency/semaphore.lux | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/stdlib/source/library/lux/control/concurrency/semaphore.lux b/stdlib/source/library/lux/control/concurrency/semaphore.lux index 789c0a28f..f7f4f5f50 100644 --- a/stdlib/source/library/lux/control/concurrency/semaphore.lux +++ b/stdlib/source/library/lux/control/concurrency/semaphore.lux @@ -58,7 +58,7 @@ [[_ state'] (atom.update! (|>> (update@ #open_positions dec) (if> [<had_open_position?>] [] - [(update@ #waiting_list (queue.push sink))])) + [(update@ #waiting_list (queue.end sink))])) semaphore)] (with_expansions [<go_ahead> (sink []) <get_in_line> (in false)] @@ -83,12 +83,12 @@ state (|> state (update@ #open_positions inc) - (update@ #waiting_list queue.pop)))) + (update@ #waiting_list queue.next)))) semaphore)] (if (same? pre post) (in (exception.except ..semaphore_is_maxed_out [(get@ #max_positions pre)])) (do ! - [_ (case (queue.peek (get@ #waiting_list pre)) + [_ (case (queue.front (get@ #waiting_list pre)) #.None (in true) |