Formed in 2009, the Archive Team (not to be confused with the archive.org Archive-It Team) is a rogue archivist collective dedicated to saving copies of rapidly dying or deleted websites for the sake of history and digital heritage. The group is 100% composed of volunteers and interested parties, and has expanded into a large amount of related projects for saving online and digital history.
IWorker 
Promise-based wrapper for worker_threads
Install
npm install iworkerUsing
const { WorkerGroup } = require('iworker');
const wg = new WorkerGroup();Object schema based
Just put object schema with methods and magical iworker do others
const worker = wg.newThread({
async foo(bar, baz) {
return 'foo' + bar + baz;
}
});
await worker.foo('bar', 'baz'); // foobarbazFactory based
You can define methods from factory-function
const worker = wg.newThread((worker) => {
const crypto = require('crypto');
worker.def('randomBytes', async (size) => {
return crypto.randomBytes(size);
});
});
await worker.randomBytes(32); // Buffer(32) Emit events during execution
When you want to send some events during the execution of the function
const worker = wg.newThread({
async foo() {
this.sendEvent('started');
this.sendEvent('progress', 99);
return 'bar';
}
});
const res = await worker.foo()
.on('started', () => {
// do some job
})
.on('progress', (per) => {
// do some job
});
// res - "baz"Send transferable objects
Instead of copying data, you can move them using Worker Transferable Objects
const worker = wg.newThread({
async foo(buf) { return buf.toString('hex')}
});
const buf = Buffer.from('Hello', 'utf8');
const hex = buf.toString('hex');
const res = await worker.foo(buf).withTransferList([buf.buffer]);
assert.strictEqual(res, hex);
assert.strictEqual(buf.length, 0);Return transferable objects from worker
const worker = wg.newThread({
async foo() {
const buf = Buffer.from('hello', 'utf8');
this.setTransferList([buf.buffer]);
return buf;
}
});
const buf = await worker.foo();Pure event-emitter
You can use iworker as pure event-emitter
const worker = wg.newThread((w) => {
w.on('event', (...args) => w.emit('eventBack', 'arg1', 'arg2'));
});
worker.on('eventBack', (arg1, arg2) => {
// some code
});
worker.emit('event', 'arg');