Implements Webworker-based processor for @pooley/core
npm install @pooley/webworker> Implements Webworker-based processor for @pooley/core.
Allows to execute tasks in a pool using Webworkers to fully parallelize pool processing.
Note: Since a task is executed in a different thread it cannot use any scoped variables from it's original thread as they will not exist in a Webworker thread - so use task arguments to pass all the nesessary data into a task.
Install the library with it's core peer dependency:
``
npm install @pooley/webworker @pooley/core
`ts
import { WorkerPool } from '@pooley/core';
import { WebWorkerProcessor } from '@pooley/webworker';
// Create a task that will be executed in a WebWorker
const task: WorkerTask
while (Date.now() - start < 1000) {
// Fully blocking the thread is fine here...
}
return data;
};
// Create a pool with webworker processor factory
const pool = new WorkerPool({
task,
queue,
poolScaler,
processorFactory: new WebWorkerProcessorFactory(),
});
`
Run nx build webworker to build the library.
Run nx test webworker` to execute the unit tests via Jest.