30 lines
832 B
TypeScript
30 lines
832 B
TypeScript
import { availableParallelism } from 'os';
|
|
import pLimit from 'p-limit';
|
|
import { join } from 'path';
|
|
import { sumArray } from '../../utils/array.ts';
|
|
|
|
const workerFile = new URL('worker.ts', import.meta.url).href;
|
|
|
|
const eva = (i: number) =>
|
|
new Promise<number>((resolve) => {
|
|
const worker = new Worker(workerFile);
|
|
|
|
worker.postMessage(i);
|
|
worker.onmessage = (event) => {
|
|
console.log('row:', i, 'found', event.data);
|
|
resolve(event.data as number);
|
|
};
|
|
});
|
|
|
|
const input = await Bun.file(join(__dirname, 'input.txt')).text();
|
|
const rowCount = input.split('\n').length;
|
|
|
|
const work = new Array(rowCount).fill(0).map((_, i) => i);
|
|
|
|
const limit = pLimit(availableParallelism());
|
|
const solution = await Promise.all(work.map((w) => limit(eva, w)));
|
|
|
|
console.log(solution);
|
|
|
|
console.log(sumArray(solution));
|