Partilhe alguns threads de trabalho com NEWTHREADPOOL()

Total.js 5 · total5@0.0.19 workerthreadpoolperformance Executada com o Total.js 5

NEWTHREAD() arranca um worker. Quando muitos pedidos precisam do mesmo trabalho pesado, um worker por pedido é demais e um único worker faz com que esperem uns pelos outros sem qualquer ordem. NEWTHREADPOOL(name, count, [isfork]) arranca count workers de workers/name.js (um thread; com isfork em true, um processo filho, como NEWFORK()) e distribui-os um de cada vez.

pool.exec(function(worker, release) {}) espera até haver um worker livre e chama a sua função com ele. Envie-lhe o trabalho com worker.postMessage(value), leia a resposta com worker.once('message', fn) e chame release() quando terminar: o worker volta ao pool e o próximo trabalho à espera fica com ele.
Sem função, pool.exec() devolve uma promessa que se resolve com worker (e o worker tem worker.release()), pelo que funciona com await.
Os trabalhos são atendidos pela ordem em que pediram. O pool não põe em fila as mensagens de um worker: um trabalho de cada vez tem-no.
O pool também é guardado em F.workers[name]. pool.workers é a lista dos workers.

O ficheiro do worker é o mesmo que para NEWTHREAD(): NEWTHREAD() lá dentro devolve o manipulador com worker.message e worker.postMessage(). Aqui cada worker soma os números e diz que thread o fez.

workers/total.js

require('total5');

const worker = NEWTHREAD();

worker.message = function(message) {
	let total = 0;
	for (let i = 1; i <= message.to; i++)
		total += i;
	worker.postMessage({ to: message.to, total: total, thread: require('worker_threads').threadId });
};

controllers/total.js

exports.install = function() {
	ROUTE('GET /total/{to}/', total);
	ROUTE('GET /await/{to}/', total_await);
	ROUTE('GET /workers/', workers);
};

const pool = NEWTHREADPOOL('total', 2);

function total($) {
	pool.exec(function(worker, release) {
		worker.once('message', function(response) {
			release();
			$.json(response);
		});
		worker.postMessage({ to: +$.params.to });
	});
}

async function total_await($) {
	const worker = await pool.exec();
	worker.once('message', function(response) {
		worker.release();
		$.json(response);
	});
	worker.postMessage({ to: +$.params.to });
}

function workers($) {
	$.json({ workers: pool.workers.length, registered: F.workers.total === pool });
}