branch fixes

1 files changed, 8 insertions, 0 deletions

diff --git a/src/ThreadSafeQueue.zig b/src/ThreadSafeQueue.zig
index b014017736..1cf6aaaa3a 100644
--- a/src/ThreadSafeQueue.zig
+++ b/src/ThreadSafeQueue.zig
@@ -59,5 +59,13 @@ pub fn ThreadSafeQueue(comptime T: type) type {
             self.state = .run;
             return was_waiting;
         }
+
+        /// Safe only to call exactly once when initially starting the worker.
+        pub fn start(self: *Self) bool {
+            assert(self.state == .wait);
+            if (self.shared.items.len == 0) return false;
+            self.state = .run;
+            return true;
+        }
     };
 }