| ... | @@ -444,7 +444,7 @@ test "Futex - Broadcast" { | ... | @@ -444,7 +444,7 @@ test "Futex - Broadcast" { |
| 444 | } | 444 | } |
| 445 | | 445 | |
| 446 | try (struct { | 446 | try (struct { |
| 447 | threads: [10]*std.Thread = undefined, | 447 | threads: [10]std.Thread = undefined, |
| 448 | broadcast: Atomic(u32) = Atomic(u32).init(0), | 448 | broadcast: Atomic(u32) = Atomic(u32).init(0), |
| 449 | notified: Atomic(usize) = Atomic(usize).init(0), | 449 | notified: Atomic(usize) = Atomic(usize).init(0), |
| 450 | | 450 | |
| ... | @@ -475,7 +475,7 @@ test "Futex - Broadcast" { | ... | @@ -475,7 +475,7 @@ test "Futex - Broadcast" { |
| 475 | for (self.threads) |*thread| | 475 | for (self.threads) |*thread| |
| 476 | thread.* = try std.Thread.spawn(runReceiver, &self); | 476 | thread.* = try std.Thread.spawn(runReceiver, &self); |
| 477 | defer for (self.threads) |thread| | 477 | defer for (self.threads) |thread| |
| 478 | thread.wait(); | 478 | thread.join(); |
| 479 | | 479 | |
| 480 | std.time.sleep(16 * std.time.ns_per_ms); | 480 | std.time.sleep(16 * std.time.ns_per_ms); |
| 481 | self.broadcast.store(BROADCAST_SENT, .Monotonic); | 481 | self.broadcast.store(BROADCAST_SENT, .Monotonic); |