try with busy workers again

Author: Simn

.github/workflows/main.yml

@@ -11,7 +11,7 @@ jobs:
       fail-fast: false
       matrix:
         os: [macos-latest, ubuntu-latest, windows-latest]
-        target: [jvm, cpp]
+        target: [jvm, cpp, hl]
         exclude:
           # php is not available by default for macos runners, probably not worth bothering
           - os: macos-latest

src/hxcoro/CoroRun.hx

@@ -122,7 +122,7 @@ class CoroRun {
 		}
 	}
 
-	#elseif (jvm || cpp)
+	#elseif (jvm || cpp || hl)
 
 	static public function runWith<T>(context:Context, lambda:NodeLambda<T>):T {
 		final scheduler = new EventLoopScheduler();

src/hxcoro/thread/FixedThreadPool.hx

@@ -237,37 +237,48 @@ private class Worker {
 				inShutdown = false;
 				continue;
 			}
-			// If we did nothing, wait for the condition variable.
-			if (cond.tryAcquire()) {
-				if (shutdownCallback != null) {
-					if (inShutdown) {
-						--activity.activeWorkers;
-						--activity.availableWorkers;
-						cond.broadcast();
-						cond.release();
-						break;
-					} else {
-						inShutdown = true;
-						cond.broadcast();
-						cond.release();
-						continue;
-					}
-				}
-				if (activity.activeWorkers == 1) {
-					cond.broadcast();
-					cond.release();
+			if (shutdownCallback != null) {
+				if (inShutdown) {
+					break;
+				} else {
+					inShutdown = true;
+					BackOff.backOff();
 					continue;
 				}
-				// These modifications are fine because we hold onto the cond mutex.
-				--activity.activeWorkers;
-				state = Waiting;
-				cond.wait();
-				state = CheckingQueues;
-				++activity.activeWorkers;
-				cond.release();
-			} else {
-				BackOff.backOff();
 			}
+			BackOff.backOff();
+
+			// If we did nothing, wait for the condition variable.
+			// if (cond.tryAcquire()) {
+			// 	if (shutdownCallback != null) {
+			// 		if (inShutdown) {
+			// 			--activity.activeWorkers;
+			// 			--activity.availableWorkers;
+			// 			cond.broadcast();
+			// 			cond.release();
+			// 			break;
+			// 		} else {
+			// 			inShutdown = true;
+			// 			cond.broadcast();
+			// 			cond.release();
+			// 			continue;
+			// 		}
+			// 	}
+			// 	if (activity.activeWorkers == 1) {
+			// 		cond.broadcast();
+			// 		cond.release();
+			// 		continue;
+			// 	}
+			// 	// These modifications are fine because we hold onto the cond mutex.
+			// 	--activity.activeWorkers;
+			// 	state = Waiting;
+			// 	cond.wait();
+			// 	state = CheckingQueues;
+			// 	++activity.activeWorkers;
+			// 	cond.release();
+			// } else {
+			// 	BackOff.backOff();
+			// }
 		}
 	}