web-worker-helper

Forked from @loaders.gl/worker-utils implementation

Time consuming task

1// fibonacci.js
2export function fibonacci(n: number) {
3  let n1 = 1,
4    n2 = 1,
5    sum = 1;
6  for (let i = 3; i <= n; i += 1) {
7    sum = n1 + n2;
8    n1 = n2;
9    n2 = sum;
10  }
11  return sum;
12}

Creating workers for time-consuming task

1// fibonacci.worker.js
2import { createWorker } from 'web-worker-helper';
3import { fibonacci } from './fibonacci';
4
5createWorker(async (data: number) => {
6  const result = fibonacci(data);
7  return result;
8});

Bundle worker

Main thread call worker

1. parse worker

1import { WorkerFarm } from 'web-worker-helper';
2
3export async function parseWorker(
4  workerName: string,
5  data: any,
6  options?: Record<string, any> = { maxConcurrency: 3, reuseWorkers: true }
7) {
8  const url = getWorkerURL({ name: workerName });
9  // const source = `fibonacci codeString`
10  const workerFarm = WorkerFarm.getWorkerFarm({
11    maxConcurrency: options.maxConcurrency,
12    reuseWorkers: options.reuseWorkers,
13  });
14  const workerPool = workerFarm.getWorkerPool({ name: workerName, url });
15  // const workerPool = workerFarm.getWorkerPool({ name: workerName, source });
16  const job = await workerPool.startJob(workerName, (job, type, data) => job.done(data));
17
18  job.postMessage('process', { input: data });
19
20  const result = await job.result;
21  return result.result;
22}

2. Call time-consuming task

1import { parseWorker } from './parse-worker';
2import { fibonacci } from './fibonacci';
3
4export async function starFibonacci(iskorker, data) {
5  if (iskorker) {
6    const result = await parseWorker('fibonacci-worker', data, {});
7    return result;
8  }
9
10  const result = await fibonacci(data);
11  return result;
12}