HFXWorker

HFXWorker is a worker_threads pool implementation that supports passing buffers.

• Focused on performance
• Uses generic-pool
• Unit and E2E tested

npm install --save hfxworker

Quick Start

Create a file named pool.js:

import { createWorkerPool } from 'hfxworker';
import path from 'path';

const execute = async () => {

	const pool = createWorkerPool(
		path.join(__dirname, 'worker.js')
	);

	const sum = pool.getMethod('sum');

	const b = Buffer.from([0, 0, 0, 0]);
	b.writeUInt32LE(2, 0);

	const result = await sum({
		releaseBefore: false,
		data: {
			a: 1,
		},
		buffers: {
			b,
		},
	});
	
	console.log(Buffer.from(result.buffers.c).readUInt32LE(0));
	console.log(result.data.c);

	await pool.drain();
	await pool.clear();

}

execute().catch((error) => console.error(error));

And another file as worker.js:

import { exposeWorker } from 'hfxworker';

exposeWorker({
	sum: async (task) => {
		const c = task.data.a + Buffer.from(task.buffers.b).readUInt32LE(0);
		const cBuffer = Buffer.from([0, 0, 0, 0]);
		cBuffer.writeUInt32LE(c, 0);
		return {
			data: {
				c
			},
			buffers: {
				c: cBuffer
			}
		};
	}
});

Now you just need to run node pool.js!

API Documentation

Your can learn more about HFXWorker API clicking here.

Related Projects

• HFXBus - Redis backed high frequency exchange bus for NodeJS.
• HFXEventStash - A high performance event store to persist commands (CQRS).