# Néhány munkaszál megosztása a NEWTHREADPOOL()-lal

> Indítson fix számú workert, kérjen kölcsön egyet a pool.exec()-kel, ha van munka, adja vissza a release()-szel, és hagyja, hogy a többi feladat szabad workerre várjon.

Framework: total5
Product: Total.js 5 (total5@0.0.19)
Language: hu
Content-SHA256: 8d756f5db9c9e344d788f22531f8751992d51a740567456a42522f2ec669f549
Snapshot: c0700e321579725c5cf4f5ace1ad7d2866d1b4f93c24a63c0b41b6b7998e976c
Sources: total5-installed@total5@0.0.19
Review: not-recorded

A `NEWTHREAD()` egy workert indít. Ha sok kérésnek ugyanarra a nehéz munkára van szüksége, kérésenként egy worker túl sok, egyetlen worker pedig sorrend nélkül egymásra várakoztatja őket. A `NEWTHREADPOOL(name, count, [isfork])` `count` workert indít a `workers/<name>.js` fájlból (egy szálat; ha az `isfork` értéke `true`, gyermekfolyamatot, mint a `NEWFORK()`), és egyenként osztja ki őket.

- A `pool.exec(function(worker, release) {})` megvárja, amíg egy worker szabad, és meghívja vele a függvényét. Küldje el neki a munkát a `worker.postMessage(value)`-val, olvassa a választ a `worker.once('message', fn)`-nel, és **hívja meg a `release()`-t, ha végzett**: a worker visszatér a poolba, és a következő várakozó feladat átveszi.
- Függvény nélkül a `pool.exec()` egy promise-t ad vissza, amely a `worker`-rel teljesül (és a workernek van `worker.release()`-e), így `await`-tel is működik.
- A feladatokat a kérés sorrendjében szolgálja ki. A pool nem sorba állítja a worker üzeneteit: egyszerre egy feladat birtokolja.
- A pool az `F.workers[name]`-ben is megmarad. A `pool.workers` a workerek listája.

A worker fájlja ugyanaz, mint a `NEWTHREAD()` esetében: benne a `NEWTHREAD()` a `worker.message` és `worker.postMessage()` kezelőt adja vissza. Itt minden worker összeadja a számokat, és megmondja, melyik szál végezte.

```js 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 });
};
```

```js 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 });
}
```