Workers is the library for multi-threading in MatrixAI's JavaScript/TypeScript applications. It is based on top of threads.js.
Currently no support for Mobile OSes.
Note that only ArrayBuffer
can be zero-copy transferred to the worker threads. This means if you are wroking with Node Buffer
you must first slice and copy the ArrayBuffer
out of the Node Buffer
.
const b = Buffer.from('hello world');
const ab = b.buffer.slice(b.byteOffset, b.byteOffset + b.byteLength);
The following diagram is an example architecture of using ArrayBuffer
:
┌───────────────────────┐
│ Main Thread │
│ │
│ ┌───────────┐ │
│ │Node Buffer│ │
│ └─────┬─────┘ │ ┌────────────────────────┐
│ │ │ │ │
│ Slice │ Copy │ │ Worker Thread │
│ │ │ │ │
│ ┌────────▼────────┐ │ Transfer │ ┌──────────────────┐ │
│ │Input ArrayBuffer├──┼──────────┼──► │ │
│ └─────────────────┘ │ │ └─────────┬────────┘ │
│ │ │ │ │
│ │ │ Compute │ │
│ │ │ │ │
│ ┌─────────────────┐ │ │ ┌─────────▼────────┐ │
│ │ ◄──┼──────────┼──┤Output ArrayBuffer│ │
│ └─────────────────┘ │ Transfer │ └──────────────────┘ │
│ │ │ │
│ │ │ │
└───────────────────────┘ └────────────────────────┘
See the benchmarks and tests for examples of using this library.
npm install --save @matrixai/workers
Run nix-shell
, and once you're inside, you can use:
# install (or reinstall packages from package.json)
npm install
# build the dist
npm run build
# run the repl (this allows you to import from ./src)
npm run ts-node
# run the tests
npm run test
# lint the source code
npm run lint
# automatically fix the source
npm run lintfix
npm run bench
View benchmarks here: https://github.com/MatrixAI/js-workers/blob/master/benches/results/WorkerManager.chart.html with https://raw.githack.com/
npm run docs
See the docs at: https://matrixai.github.io/js-workers/
Publishing is handled automatically by the staging pipeline.
Prerelease:
# npm login
npm version prepatch --preid alpha # premajor/preminor/prepatch
git push --follow-tags
Release:
# npm login
npm version patch # major/minor/patch
git push --follow-tags
Manually:
# npm login
npm version patch # major/minor/patch
npm run build
npm publish --access public
git push
git push --tags