深入领略Node.js 历程与线程(8000字长文彻底搞懂)

master.js 首要处理赏罚以下逻辑：

• 建设一个 server 并监听 3000 端口。
• 按照体系 cpus 开启多个子历程
• 通过子历程工具的 send 要领发送动静到子历程举办通讯
• 在主历程中监听了子历程的变革，假如是自杀信号从头启动一个事变历程。
• 主历程在监听到退出动静的时辰，先退出子历程在退出主历程

// master.js 
const fork = require('child_process').fork; 
const cpus = require('os').cpus(); 
 
const server = require('net').createServer(); 
server.listen(3000); 
process.title = 'node-master' 
 
const workers = {}; 
const createWorker = () => { 
    const worker = fork('worker.js') 
    worker.on('message', function (message) { 
        if (message.act === 'suicide') { 
            createWorker(); 
        } 
    }) 
    worker.on('exit', function(code, signal) { 
        console.log('worker process exited, code: %s signal: %s', code, signal); 
        delete workers[worker.pid]; 
    }); 
    worker.send('server', server); 
    workers[worker.pid] = worker; 
    console.log('worker process created, pid: %s ppid: %s', worker.pid, process.pid); 
} 
 
for (let i=0; i<cpus.length; i++) { 
    createWorker(); 
} 
 
process.once('SIGINT', close.bind(this, 'SIGINT')); // kill(2) Ctrl-C 
process.once('SIGQUIT', close.bind(this, 'SIGQUIT')); // kill(3) Ctrl- 
process.once('SIGTERM', close.bind(this, 'SIGTERM')); // kill(15) default 
process.once('exit', close.bind(this)); 
 
function close (code) { 
    console.log('历程退出！', code); 
 
    if (code !== 0) { 
        for (let pid in workers) { 
            console.log('master process exited, kill worker pid: ', pid); 
            workers[pid].kill('SIGINT'); 
        } 
    } 
 
    process.exit(0); 
} 

事变历程

（编辑：湖南网）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!