Fix blocking tests deadlocking on low hardwareConcurrency environments

Author: W4G1

test/barrier.test.ts

@@ -1,5 +1,8 @@
 import { assert, assertEquals } from "@std/assert";
 import { Barrier, move, spawn } from "../src/deno/lib.ts";
+import { initRuntime } from "../src/lib/lib.ts";
+
+initRuntime({ maxWorkers: 8 });
 
 Deno.test("Barrier: Basic Rendezvous (N=3)", async () => {
   const barrier = new Barrier(3);

test/mutex_sync.test.ts

@@ -1,4 +1,7 @@
 import { move, Mutex, spawn } from "../src/deno/lib.ts";
+import { initRuntime } from "../src/lib/lib.ts";
+
+initRuntime({ maxWorkers: 2 });
 
 Deno.test("Mutex sync", async () => {
   const sharedInt = new Int32Array(

test/rwlock_concurrent_writers.test.ts

@@ -1,5 +1,11 @@
 import { assertEquals } from "@std/assert";
 import { move, RwLock, spawn } from "../src/deno/lib.ts";
+import { initRuntime } from "../src/lib/lib.ts";
+
+const THREAD_COUNT = 4;
+const INCREMENTS_PER_THREAD = 50;
+
+initRuntime({ maxWorkers: 4 });
 
 Deno.test("RwLock: Concurrent Writers (Data Integrity Check)", async () => {
   // 1. Setup Shared Memory
@@ -12,8 +18,6 @@ Deno.test("RwLock: Concurrent Writers (Data Integrity Check)", async () => {
   const lock = new RwLock(data);
 
   // 2. Define Configuration
-  const THREAD_COUNT = 4;
-  const INCREMENTS_PER_THREAD = 50;
   // Total expected value: 200 (fits within Uint8 range of 0-255)
 
   // 3. Define Worker Task

test/semaphore_rate_limiting.test.ts

@@ -1,5 +1,8 @@
 import { assertLess } from "@std/assert";
 import { move, Semaphore, spawn } from "../src/deno/lib.ts";
+import { initRuntime } from "../src/lib/lib.ts";
+
+initRuntime({ maxWorkers: 3 });
 
 Deno.test("Semaphore Rate Limiting (Sync + 'using')", async () => {
   // Allow 2 threads at once.