Merge pull request #1 from Corendos/fix/kqueue-too-many-events

Fix/kqueue too many events

Author: Corendos

src/ThreadPool.zig

@@ -335,12 +335,8 @@ fn unregister(noalias self: *ThreadPool, noalias maybe_thread: ?*Thread) void {
 
 fn join(self: *ThreadPool) void {
     // Wait for the thread pool to be shutdown() then for all threads to enter a joinable state
-    var sync: Sync = @bitCast(self.sync.load(.monotonic));
-    if (!(sync.state == .shutdown and sync.spawned == 0)) {
-        self.join_event.wait();
-        sync = @bitCast(self.sync.load(.monotonic));
-    }
-
+    self.join_event.wait();
+    const sync: Sync = @bitCast(self.sync.load(.monotonic));
     assert(sync.state == .shutdown);
     assert(sync.spawned == 0);
 

src/backend/kqueue.zig

@@ -437,6 +437,9 @@ pub const Loop = struct {
                     // Only resubmit if we aren't already active (in the queue)
                     .rearm => if (!c_active) self.submissions.push(c),
                 }
+
+                // If we filled the events slice, we break to avoid overflow.
+                if (changes == events.len) break;
             }
 
             // Determine our next timeout based on the timers