ref: 3c7cf598f83d27ac3b98e0061075052f9f9baaf1
dir: /lib/thread/waitgrp.myr/
use std use "atomic" pkg thread = type waitgrp = struct _val : uint32 ;; const mkwg : (v : uint32 -> waitgrp) const wgwait : (w : waitgrp# -> void) const wgpost : (w : waitgrp# -> void) ;; const mkwg = {v -> [._val = v] } const wgwait = {w for var i = 0; i < 1000; i++ if xget(&w._val) == 0 -> void ;; ;; for var i = 0; i < 1000; i++ if xget(&w._val) == 0 -> void ;; std.nanosleep(10_000) ;; for var i = 0; i < 1000; i++ if xget(&w._val) == 0 -> void ;; std.nanosleep(100_000) ;; for ; ; if xget(&w._val) == 0 -> void ;; std.nanosleep(1_000_000) ;; } const wgpost = {w std.assert(xadd(&w._val, -1) > 0, "error: waitgroup underflowed\n") }