ym
Size: a a a
ym
OS
if (isMaster) {
console.info(`Master ${process.pid} is running`);
const cores = cpus().length;
const workers = [];
for (let i = 0; i < cores; i++) {
workers.push(fork());
}
let forks = 0;
const master = new Telegraf(process.env.TOKEN);
master.handleUpdate = function(update) {
if (forks < 0) {
forks = cores - 1;
}
workers[forks--].send(update);
return Promise.resolve();
};
master.launch();
} else {
console.info(`Worker ${process.pid} started`);
const bot = require('./app');
process.on('message', (update) => {
bot.handleUpdate(update);
});
}
☔
ym
E
☔
E
OS
JD
E
E
☔
JD
E
☔
E
☔
j
j
E