added async-io quiz

12 files changed, 187 insertions, 0 deletions

diff --git a/patches/patches/084_interfaces.patch b/patches/patches/084_interfaces.patch
new file mode 100644
index 0000000..a1d0628
--- /dev/null
+++ b/patches/patches/084_interfaces.patch
@@ -0,0 +1,11 @@
+--- exercises/084_interfaces.zig	2025-08-15 15:17:57.839348063 +0200
++++ answers/084_interfaces.zig	2026-04-03 14:27:32.670756488 +0200
+@@ -106,7 +106,7 @@
+     for (my_insects) |insect| {
+         // Almost done! We want to print() each insect with a
+         // single method call here.
+-        ???
++        insect.print();
+     }
+ }
+ 
diff --git a/patches/patches/085_async.patch b/patches/patches/085_async.patch
new file mode 100644
index 0000000..ca8b102
--- /dev/null
+++ b/patches/patches/085_async.patch
@@ -0,0 +1,11 @@
+--- exercises/085_async.zig	2026-04-01 20:40:08.904999609 +0200
++++ answers/085_async.zig	2026-04-01 20:40:05.641933231 +0200
+@@ -37,7 +37,7 @@
+ const std = @import("std");
+ 
+ pub fn main(init: std.process.Init) !void {
+-    const io = init.???;
++    const io = init.io;
+ 
+     // Get the current wall-clock time using the Io interface.
+     // Hint: Timestamp.now() takes an Io and a Clock type (.real = wall clock).
diff --git a/patches/patches/086_async2.patch b/patches/patches/086_async2.patch
new file mode 100644
index 0000000..7506a69
--- /dev/null
+++ b/patches/patches/086_async2.patch
@@ -0,0 +1,14 @@
+--- exercises/086_async2.zig	2026-04-01 19:22:50.017227542 +0200
++++ answers/086_async2.zig	2026-04-01 19:21:57.569158481 +0200
+@@ -38,9 +38,9 @@
+ 
+     // Now collect the result. What method on Future gives us
+     // the value, blocking if it isn't ready yet?
+-    const answer = future.???(io);
++    const answer = future.await(io);
+ 
+-    std.debug.print("The answer is: {}\n", .{answer});
++    std.debug.print("the answer is: {}\n", .{answer});
+ }
+ 
+ fn computeAnswer(a: u32, b: u32) u32 {
diff --git a/patches/patches/087_async3.patch b/patches/patches/087_async3.patch
new file mode 100644
index 0000000..8365e7a
--- /dev/null
+++ b/patches/patches/087_async3.patch
@@ -0,0 +1,18 @@
+--- exercises/087_async3.zig	2026-04-01 22:51:05.540094851 +0200
++++ answers/087_async3.zig	2026-04-01 22:50:44.579669189 +0200
+@@ -29,12 +29,12 @@
+     const io = init.io;
+ 
+     // Launch both tasks asynchronously.
+-    var future_a = io.async(slowAdd, .{ 10, 20 });
+-    var future_b = ???(slowMul, .{ 6, 7 });
++    var future_a = io.async(slowAdd, .{ 1, 2 });
++    var future_b = io.async(slowMul, .{ 6, 7 });
+ 
+     // Await both results.
+     const sum = future_a.await(io);
+-    const product = future_b.???(io);
++    const product = future_b.await(io);
+ 
+     print("{} + {} = {}\n", .{ 1, 2, sum });
+     print("{} * {} = {}\n", .{ 6, 7, product });
diff --git a/patches/patches/088_async4.patch b/patches/patches/088_async4.patch
new file mode 100644
index 0000000..1faf30e
--- /dev/null
+++ b/patches/patches/088_async4.patch
@@ -0,0 +1,11 @@
+--- exercises/088_async4.zig	2026-04-01 23:17:31.066443941 +0200
++++ answers/088_async4.zig	2026-04-01 23:17:39.251612131 +0200
+@@ -38,7 +38,7 @@
+ 
+     // Wait for all tasks to finish.
+     // What Group method blocks until all tasks complete?
+-    try group.???
++    try group.await(io);
+ 
+     print("All tasks finished!\n", .{});
+ }
diff --git a/patches/patches/089_async5.patch b/patches/patches/089_async5.patch
new file mode 100644
index 0000000..d2baa96
--- /dev/null
+++ b/patches/patches/089_async5.patch
@@ -0,0 +1,11 @@
+--- exercises/089_async5.zig	2026-04-01 23:40:40.505855238 +0200
++++ answers/089_async5.zig	2026-04-01 23:40:10.176236971 +0200
+@@ -40,7 +40,7 @@
+ 
+     // We don't want to wait 10 seconds!
+     // Which Future method requests cancellation AND returns the result?
+-    const result = ???;
++    const result = future.cancel(io);
+ 
+     print("Task returned: {}\n", .{result});
+ }
diff --git a/patches/patches/090_async6.patch b/patches/patches/090_async6.patch
new file mode 100644
index 0000000..5ac777b
--- /dev/null
+++ b/patches/patches/090_async6.patch
@@ -0,0 +1,11 @@
+--- exercises/090_async6.zig	2026-04-02 10:25:34.016616118 +0200
++++ answers/090_async6.zig	2026-04-02 10:27:48.827144051 +0200
+@@ -47,7 +47,7 @@
+ 
+     // Wait for the first finisher.
+     // What Select method returns the first completed result?
+-    const winner = ???;
++    const winner = try sel.await();
+ 
+     switch (winner) {
+         .hare => |msg| print("Hare: {s}\n", .{msg}),
diff --git a/patches/patches/091_async7.patch b/patches/patches/091_async7.patch
new file mode 100644
index 0000000..b4bab9b
--- /dev/null
+++ b/patches/patches/091_async7.patch
@@ -0,0 +1,13 @@
+--- exercises/091_async7.zig	2026-04-02 10:50:08.142508099 +0200
++++ answers/091_async7.zig	2026-04-02 10:49:59.629341593 +0200
+@@ -49,8 +49,8 @@
+     for (0..times) |_| {
+         // Acquire the lock before modifying shared state.
+         // What Mutex method blocks until the lock is acquired?
+-        state.mutex.??? catch return;
+-        defer state.mutex.unlock(); // <-- what's missing here?
++        state.mutex.lock(io) catch return;
++        defer state.mutex.unlock(io);
+ 
+         state.counter += 1;
+     }
diff --git a/patches/patches/092_async8.patch b/patches/patches/092_async8.patch
new file mode 100644
index 0000000..0ec9116
--- /dev/null
+++ b/patches/patches/092_async8.patch
@@ -0,0 +1,11 @@
+--- exercises/092_async8.zig	2026-04-02 10:49:27.925721496 +0200
++++ answers/092_async8.zig	2026-04-02 10:49:31.694795212 +0200
+@@ -43,7 +43,7 @@
+     // Send numbers 1 through 10 into the queue.
+     for (1..11) |i| {
+         // What Queue method sends a single element, blocking if full?
+-        queue.???(io, @intCast(i)) catch return;
++        queue.putOne(io, @intCast(i)) catch return;
+     }
+     // Signal that we're done sending.
+     queue.close(io);
diff --git a/patches/patches/093_async9.patch b/patches/patches/093_async9.patch
new file mode 100644
index 0000000..f759921
--- /dev/null
+++ b/patches/patches/093_async9.patch
@@ -0,0 +1,11 @@
+--- exercises/093_async9.zig	2026-04-03 13:44:50.526780809 +0200
++++ answers/093_async9.zig	2026-04-03 13:44:54.957870294 +0200
+@@ -36,7 +36,7 @@
+     // Launch with a guaranteed separate thread.
+     // Which Io method guarantees true concurrency?
+     // (Hint: unlike io.async, this one can fail!)
+-    var future = try io.???(compute, .{io});
++    var future = try io.concurrent(compute, .{io});
+ 
+     print("Main thread continues...\n", .{});
+ 
diff --git a/patches/patches/094_async10.patch b/patches/patches/094_async10.patch
new file mode 100644
index 0000000..ae0d26d
--- /dev/null
+++ b/patches/patches/094_async10.patch
@@ -0,0 +1,13 @@
+--- exercises/094_async10.zig	2026-04-03 14:25:16.600025924 +0200
++++ answers/094_async10.zig	2026-04-03 14:24:56.192615893 +0200
+@@ -50,8 +50,8 @@
+ 
+     // Protect this section from cancellation.
+     // What method swaps the cancel protection state?
+-    const old = io.???(. blocked);
+-    defer _ = io.???(old);
++    const old = io.swapCancelProtection(.blocked);
++    defer _ = io.swapCancelProtection(old);
+ 
+     // This sleep will NOT return error.Canceled even though
+     // we get canceled during it — protection is active!
diff --git a/patches/patches/095_quiz_async.patch b/patches/patches/095_quiz_async.patch
new file mode 100644
index 0000000..dbaae07
--- /dev/null
+++ b/patches/patches/095_quiz_async.patch
@@ -0,0 +1,52 @@
+--- exercises/095_quiz_async.zig	2026-04-03 18:04:53.577391455 +0200
++++ answers/095_quiz_async.zig	2026-04-03 18:05:42.570392172 +0200
+@@ -51,7 +51,7 @@
+         // Bug 1: The collector needs to lock before modifying
+         // shared state. What Mutex method acquires the lock?
+         self.mutex.lock(io) catch return;
+-        self.mutex.???(io) catch return;
++        defer self.mutex.unlock(io);
+ 
+         switch (reading.sensor_type) {
+             .thermometer => self.temperature = reading.value,
+@@ -79,9 +79,9 @@
+     // Bug 2: io.async doesn't guarantee a separate thread.
+     // Which Io method guarantees true concurrency?
+     // (Don't forget: it can fail, so you need 'try'!)
+-    try sensors.???(io, sensor, .{ io, &queue, .thermometer, 20 });
+-    try sensors.???(io, sensor, .{ io, &queue, .hygrometer, 60 });
+-    try sensors.???(io, sensor, .{ io, &queue, .anemometer, 10 });
++    try sensors.concurrent(io, sensor, .{ io, &queue, .thermometer, 20 });
++    try sensors.concurrent(io, sensor, .{ io, &queue, .hygrometer, 60 });
++    try sensors.concurrent(io, sensor, .{ io, &queue, .anemometer, 10 });
+ 
+     // Collector group: processes readings from the queue.
+     var collectors: std.Io.Group = .init;
+@@ -90,7 +90,6 @@
+     // Bug 3: Wait for ALL sensors to finish sending their readings.
+     // What Group method blocks until all tasks complete?
+     try sensors.await(io);
+-    // try sensors.???(io);
+ 
+     // All sensors done — close the queue so the collector knows
+     // there's no more data coming.
+@@ -104,8 +103,8 @@
+     //
+     // Bug 4: Protect this section from cancellation.
+     // What Io method swaps the cancel protection state?
+-    const old_protection = io.???(.blocked);
+-    defer _ = io.???(old_protection);
++    const old_protection = io.swapCancelProtection(.blocked);
++    defer _ = io.swapCancelProtection(old_protection);
+ 
+     printGardenReport(&weather);
+ }
+@@ -127,7 +126,7 @@
+ 
+         // Bug 5: Send the reading into the queue.
+         // What Queue method sends a single element?
+-        queue.???(io, reading) catch return;
++        queue.putOne(io, reading) catch return;
+     }
+ }
+