Работа impress с воркерами

[georgolden]

impress/impress.js

Line 53 in 847dff4

const count = ports.length + (balancer ? 1 : 0) + (workers.pool || 0);

impress/impress.js

Line 57 in 847dff4

const threads = new Array(count);

impress/impress.js

Lines 60 to 92 in 847dff4

	for (const worker of threads) {
	worker.postMessage({ type: 'event', name: 'stop' });
	}
	};
	const start = (id) => {
	const workerPath = path.join(__dirname, 'lib/worker.js');
	const worker = new Worker(workerPath, { trackUnmanagedFds: true });
	threads[id] = worker;
	worker.on('exit', (code) => {
	if (code !== 0) start(id);
	else if (--active === 0) process.exit(0);
	});
	worker.on('online', () => {
	if (++starting === count) {
	startTimer = setTimeout(() => {
	if (active !== count) console.warn('Server initialization timed out');
	}, config.server.timeouts.start);
	}
	});
	worker.on('message', (data) => {
	if (data.type === 'event' && data.name === 'started') active++;
	if (active === count && startTimer) {
	clearTimeout(startTimer);
	startTimer = null;
	}
	});
	};
	for (let id = 0; id < count; id++) start(id);

impress/lib/worker.js

Lines 76 to 79 in 847dff4

	const servingThreads = ports.length + (balancer ? 1 : 0);
	if (threadId <= servingThreads) {
	application.server = new Server(config.server, application);
	}

В impress.js мы предполагаем что воркеров всего балансер + порты + воркерпулы из конфига.
В worker.js мы раним сервер только на балансер + порты количество воркеров. Таким образом мы избегаем поведение metacom, когда он запускает порты undefined. metarhia/metacom#199
Однако оставшиеся 2 воркера нигде не используются в коде.
Зачем нужны воркер пулы? Зачем нужны воркеры, которые исполняют весь код помимо запуска сервера. Получаются лишние воркеры с пулов просто печатают в консоль, чекают конфиги, отправляют сообщение что они запустились, ждут пока им отправится сообщение на shutdown. Никакой полезно работы нет.

[tshemsedinov]

В этих воркерах нужно выполнять работу, не связанную с запросами по сети, например, читать сообщения из очередей событий и выполнять отложенные задачи, ставить таймеры при старте и выполнять что-то периодически. Когда у нас будет планировщик, то задачи из него тоже будут выполняться в этих воркерах. Если они не нужны, их можно отключить в конфигах.

[tshemsedinov]

• По поводу Listening port undefined on worker 0 metacom#199 я посмотрел и разобрался: thread 0 используется для управления потоками и в нем мы не открывем портов.
• Как в балансировщиком, так и без балансировщика все работает отлично. Проблема была в том, что создавалось больше потоков, чем сконфигурировано. Если 2 порта сконфигурированы, то и потоков делаем: 1 (на управление) + 1 (балансировщик, если сконфигурирован) + 2 (с портами).

[georgolden]

когда человек попытается создать сервер в процессе, а не в треде, то тогда сервер метакома достанет threadId = 0. Я это имел ввиду

[tshemsedinov]

Появился еще воркед для планировщика в impress 2.5 и скоро я пепенесу выполнение тасков в пул тредов