ex: add enqueued check to workqueue

2026-10-27 21:58:20 +00:00 · 2026-06-25 21:33:33 -04:00
parent 4ba57ad42a
commit 39e85a391d
1 changed files with 4 additions and 0 deletions
@@ -123,6 +123,10 @@ pub fn enqueue(item: *WorkItem) void {
    const ipl = ke.ipl.raise(.Dispatch);
    defer ke.ipl.lower(ipl);

+    if (item.enqueued.cmpxchgStrong(false, true, .acquire, .monotonic) != null) {
+        return;
+    }
+
    var pool: *Pool = undefined;

    switch (item.priority) {