feat(loader-runner): Allow limiting worker pool size for parallel loaders

packages/rspack/etc/core.api.md

@@ -4509,7 +4509,7 @@ class LoaderObject {
     // (undocumented)
     options?: string | object;
     // (undocumented)
-    parallel?: boolean;
+    parallel?: boolean | number;
     // (undocumented)
     path: string;
     // (undocumented)
@@ -7048,7 +7048,7 @@ export type RuleSetLoaderOptions = string | Record<string, any>;
 export type RuleSetLoaderWithOptions = {
     ident?: string;
     loader: RuleSetLoader;
-    parallel?: boolean;
+    parallel?: boolean | number;
     options?: RuleSetLoaderOptions;
 };
 

packages/rspack/src/config/types.ts

@@ -872,7 +872,7 @@ export type RuleSetLoaderWithOptions = {
 
 	loader: RuleSetLoader;
 
-	parallel?: boolean;
+	parallel?: boolean | number;
 
 	options?: RuleSetLoaderOptions;
 };

packages/rspack/src/loader-runner/index.ts

@@ -144,7 +144,7 @@ export class LoaderObject {
 	pitch?: Function;
 	raw?: boolean;
 	type?: "module" | "commonjs";
-	parallel?: boolean;
+	parallel?: boolean | number;
 	/**
 	 * @internal This field is rspack internal. Do not edit.
 	 */
@@ -995,7 +995,11 @@ export async function runLoaders(
 						loaderState,
 						args
 					},
-					getWorkerLoaderHandlers()
+					getWorkerLoaderHandlers(),
+					typeof currentLoaderObject?.parallel === "number"
+						? // requested number of threads
+							currentLoaderObject.parallel
+						: undefined
 				)) || [];
 		} else {
 			if (loaderState === JsLoaderState.Normal)

packages/rspack/src/loader-runner/service.ts

@@ -3,20 +3,23 @@ import path from "node:path";
 import type { Tinypool } from "tinypool" with { "resolution-mode": "import" };
 
 let pool: Promise<Tinypool> | undefined;
-const ensureLoaderWorkerPool = async () => {
+const ensureLoaderWorkerPool = async (requestedThreads?: number) => {
 	if (pool) {
 		return pool;
 	}
 	return (pool = import("tinypool").then(({ Tinypool }) => {
 		const cpus = require("node:os").cpus().length;
 		const availableThreads = Math.max(cpus - 1, 1);
+		const threadCount = requestedThreads
+			? Math.max(requestedThreads, 1)
+			: undefined;
 
 		const pool = new Tinypool({
 			filename: path.resolve(__dirname, "worker.js"),
 			useAtomics: false,
 
-			maxThreads: availableThreads,
-			minThreads: availableThreads,
+			maxThreads: threadCount || availableThreads,
+			minThreads: threadCount || availableThreads,
 			concurrentTasksPerWorker: 1
 		});
 
@@ -199,9 +202,10 @@ export const run = async (
 	task: any,
 	options: RunOptions & {
 		handleIncomingRequest: HandleIncomingRequest;
-	}
+	},
+	requestedThreads?: number
 ) =>
-	ensureLoaderWorkerPool().then(async pool => {
+	ensureLoaderWorkerPool(requestedThreads).then(async pool => {
 		const { MessageChannel } = await import("node:worker_threads");
 		const { port1: mainPort, port2: workerPort } = new MessageChannel();
 		// Create message channel for processing sync API requests from worker

tests/rspack-test/configCases/loader-parallel/parallel-number/index.js

@@ -0,0 +1,3 @@
+it("should run loader in parallel", () => {
+	expect(require("./lib.js")).toBe(true)
+})

tests/rspack-test/configCases/loader-parallel/parallel-number/loader-in-worker.js

@@ -0,0 +1,3 @@
+module.exports = function () {
+	return `module.exports = ${this.parallel}`;
+}

tests/rspack-test/configCases/loader-parallel/parallel-number/rspack.config.js

@@ -0,0 +1,26 @@
+module.exports = {
+	context: __dirname,
+	module: {
+		rules: [
+			{
+				test: /lib\.js/,
+				use: [
+					{
+						loader: "./unclonable.js",
+						options: {
+							notclonable() {}
+						}
+					},
+					{
+						loader: "./loader-in-worker.js",
+						parallel: 2,
+						options: {}
+					}
+				]
+			}
+		]
+	},
+	experiments: {
+		parallelLoader: true
+	}
+};

tests/rspack-test/configCases/loader-parallel/parallel-number/unclonable.js

@@ -0,0 +1,3 @@
+module.exports = function(content) {
+	return content
+}