A
А на вашем ютуб канале есть что то про ваш NodejsStarterKit?
Size: a a a
2022 January 28
MS
Кто-нить знает, kittenx, ВКшный прокси-сервер, является переделанным nginx-ом?
EK
конечно правильно
r
У тебя есть канал?
СП
Переслано от Сергей Пограничный...
Господа, вопрос по worker threads и EventEmitter, простая задачка:
https://github.com/sergeyampo/NodeJS-Prime-Factorization-WorkerThreads/blob/master/concurrent.mjs#L36
считаем в воркере функцией множество простых чисел, при нагрузочных тестах нода ругается, как еще сделать, чтобы не загружать листенерами воркера?
https://github.com/sergeyampo/NodeJS-Prime-Factorization-WorkerThreads/blob/master/concurrent.mjs#L36
считаем в воркере функцией множество простых чисел, при нагрузочных тестах нода ругается, как еще сделать, чтобы не загружать листенерами воркера?
MaxListenersExceededWarning: Possible EventEmitter memory leak detected. 11 message listeners added to [Worker]. Use emitter.setMaxListeners() to increase limit
R
Не подписывайтесь на события внутри http обработчиков или циклов. Делайте подписку и обработку событий вне итерации, а внутри - только отравляйте в воркер входные данные для обработки
СП
А как мне ответить клиенту по готовности?
СП
Если покажите минимальнейший пример - буду благодарен
N
нет, если это вопрос в стиле "не нравиться - сделай сам как надо", то как я уже ответил, это тупиковый путь
R
Сделайте учёт клиентов через Map, тогда сможете доставать их в обработчике по идентификатору
TS
A
Благодарю
EK
На самом деле аргумент действительно так себе. Не можешь критиковать атомобили, потому сам не строишь и тд. Но можно и в своё русло выкрутить это - возвращается клиет недовольный с ворохом багов, а ты ему "А ты хоть сам программист?"
СП
Сериализовать Map и отправлять его в воркер что-ли? Почему Map? Воркер отвечать на запрос должен? Не понял, мало контекста
N
Я выразил свое мнение о том что лично мне хотелось бы контент по этой теме немного в другом формате.
в чем проблема?
в чем проблема?
EK
та ни в чем :) Я поддерживаю Ваше права на своё мнение. Даже пытался поддержать, но видимо неуклюже)
СП
Я бы понял, если бы мы хранили какой-то SharedWeakMap<req, value> все воркеры разбирали бы себе задачи из него конкуррентно и отвечали сразу на запрос, что думаете?
R
const clients = new Map();
worker.on('message', ({ id, result }) => {const client = clients.get(id);
client.end(result);
clients.delete(id);
});
const server = http.createServer(async (req, res) => {const id = 'some client id';
worker.postMessage({ id, data: [1, 2, 3] });clients.set(id, res);
});
server.listen(3000);
R
примитивно вот так
СП
Вообще у меня другой файл для воркера, как он узнает о Map?