Function runTaskAsync

test/BenchmarkTestCases.benchmark.mjs:647–717

(task, name, uri)

		 * @param {string} uri URI
		 */
		const runTaskAsync = async (task, name, uri) => {
			let { fn, options } =
				/** @type {TaskMeta} */
				(uriMap.get(name));

			// Custom setup
			await bench.setup?.(task, "run");

			await options?.beforeAll?.call(task, "run");

			if (
				codspeedRunnerMode === "simulation" ||
				codspeedRunnerMode === "memory"
			) {
				// Custom warmup
				// We don't run `optimizeFunction` because our function is never optimized, instead we just warmup webpack.
				// Memory mode also needs warmup so the first measured sample isn't
				// polluted by module loading, lazy webpack init, and JIT shape transitions.
				const samples = [];

				while (samples.length < warmupIterations) {
					samples.push(await iterationAsync(task, name));
				}
			}

			await options?.beforeEach?.call(task, "run");
			await mongoMeasurement.start(uri);
			// Drain heap before the instrumented region so allocations from the
			// warmup runs aren't attributed to the measured sample (especially
			// under massif). One GC can leave promoted-but-unreachable objects
			// pending finalization; finalizers themselves can allocate. Loop
			// `gc -> microtask` three times so each GC's finalizers get a chance
			// to run and any garbage they produce is collected on the next pass,
			// then drain pending IO with `setImmediate`, then one final GC to
			// catch anything the IO callbacks left behind.
			for (let i = 0; i < 3; i++) {
				global.gc?.();
				await new Promise((resolve) => {
					queueMicrotask(() => resolve(undefined));
				});
			}
			await new Promise((resolve) => {
				setImmediate(resolve);
			});
			global.gc?.();
			await wrapWithInstrumentHooksAsync(wrapFunctionWithFrame(fn, true), uri);
			await mongoMeasurement.stop(uri);
			await options?.afterEach?.call(task, "run");
			console.log(`[Codspeed] ✔ Measured ${uri}`);
			await options?.afterAll?.call(task, "run");

			// Custom teardown
			await bench.teardown?.(task, "run");

			logTaskCompletion(uri, taskCompletionMessage());

			// Release this task's closures
			fn = NO_OP_FN;