From 8403dc97514233859f71d08ba07b5a4a6b67238a Mon Sep 17 00:00:00 2001
From: Chris Duncan <chris@zoso.dev>
Date: Mon, 16 Dec 2024 13:05:17 -0800
Subject: [PATCH] Fix pool incorrectly dividing up jobs and falling short of
 distributing all data. Open up access to pool thread count by status.

---
 src/lib/pool.ts | 19 +++++++++++++++++--
 1 file changed, 17 insertions(+), 2 deletions(-)

diff --git a/src/lib/pool.ts b/src/lib/pool.ts
index 5211d2a..9c014ea 100644
--- a/src/lib/pool.ts
+++ b/src/lib/pool.ts
@@ -21,11 +21,26 @@ type Thread = {
 * Processes an array of tasks using Web Workers.
 */
 export class Pool {
-	static #threads: Thread[] = []
 	static #cores: number = Math.max(1, navigator.hardwareConcurrency - 1)
 	static #queue: Job[] = []
+	static #threads: Thread[] = []
 	static #url: string = URL.createObjectURL(new Blob([Workers], { type: 'text/javascript' }))
 
+	static get threadsBusy (): number {
+		let n = 0
+		for (const thread of this.#threads) {
+			n += +(thread.job != null)
+		}
+		return n
+	}
+	static get threadsIdle (): number {
+		let n = 0
+		for (const thread of this.#threads) {
+			n += +(thread.job == null)
+		}
+		return n
+	}
+
 	static {
 		for (let i = this.#cores; i > 0; i--) {
 			const thread = {
@@ -48,7 +63,7 @@ export class Pool {
 				thread.worker.postMessage({ name: job.name, buffer: job.data }, [job.data])
 			}
 		} else {
-			const chunk: number = 1 + (job.data.length / this.#cores)
+			const chunk: number = 1 + (job.data.length / this.threadsIdle)
 			const next = job.data.slice(0, chunk)
 			job.data = job.data.slice(chunk)
 			if (job.data.length === 0) this.#queue.shift()
-- 
2.34.1