From cb27084693c252d818db18d9a2b1ab2fbb75062e Mon Sep 17 00:00:00 2001
From: David Allemang <allemang.d@gmail.com>
Date: Mon, 21 Jul 2025 08:37:32 -0400
Subject: [PATCH] threading tests

---
 src/foo.zig  | 38 +++++++++++++++++++++++++++++++++-----
 src/main.zig |  2 +-
 2 files changed, 34 insertions(+), 6 deletions(-)

diff --git a/src/foo.zig b/src/foo.zig
index ca32e3b..44b373d 100644
--- a/src/foo.zig
+++ b/src/foo.zig
@@ -5,18 +5,46 @@ const Self = @This();
 
 export const MODULE = core.module(Self);
 
+_unload: std.Thread.ResetEvent = .{},
+looper: ?std.Thread = null,
+
 pub fn startup(_: std.mem.Allocator) !Self {
     std.log.debug("!! startup {s} !!", .{@typeName(@This())});
     return .{};
 }
 
-pub fn unload(_: *Self, _: std.mem.Allocator) ![]u8 {
-    std.log.debug("!! unload {s} !!", .{@typeName(@This())});
-    return &.{};
+pub fn reload(self: *Self, alloc: std.mem.Allocator, _: []u8) !void {
+    std.log.debug("!! reload {s} !!", .{@typeName(@This())});
+    self._unload.reset();
+    self.looper = try std.Thread.spawn(
+        .{ .allocator = alloc },
+        _loop,
+        .{self},
+    );
+    errdefer {
+        self._unload.set();
+        self.looper.?.join();
+    }
 }
 
-pub fn reload(_: *Self, _: std.mem.Allocator, _: []u8) !void {
-    std.log.debug("!! reload {s} !!", .{@typeName(@This())});
+fn _loop(self: *Self) void {
+    std.log.debug("START", .{});
+    for (0..10) |i| {
+        std.log.debug("LOOP {d}", .{i});
+        self._unload.timedWait(std.time.ns_per_s) catch continue;
+        std.log.debug("HALT", .{});
+        break;
+    }
+}
+
+pub fn unload(self: *Self, _: std.mem.Allocator) ![]u8 {
+    std.log.debug("!! unload {s} !!", .{@typeName(@This())});
+    if (self.looper) |looper| {
+        self._unload.set();
+        looper.join();
+        self.looper = null;
+    }
+    return &.{};
 }
 
 pub fn shutdown(_: *Self, _: std.mem.Allocator) void {
diff --git a/src/main.zig b/src/main.zig
index a031efd..8d908e9 100644
--- a/src/main.zig
+++ b/src/main.zig
@@ -192,7 +192,7 @@ pub fn main() !void {
     const eventbuf = try alloc.alloc(u8, 5 * (@sizeOf(linux.inotify_event) + linux.NAME_MAX));
     defer alloc.free(eventbuf);
 
-    for (0..300) |_| {
+    for (0..60 * 10) |_| {
         const n = linux.poll(&fds, fds.len, std.time.ms_per_s);
 
         if (n > 0) {