在Linux中,Node.js可以通过多种方式实现并发处理。以下是一些常见的方法:
const fs = require('fs'); fs.readFile('file1.txt', 'utf8', (err, data) => { if (err) throw err; console.log(data); }); fs.readFile('file2.txt', 'utf8', (err, data) => { if (err) throw err; console.log(data); });
事件循环:Node.js使用事件驱动模型来处理并发。事件循环允许Node.js在等待异步操作完成时继续执行其他任务。当异步操作完成时,事件循环会将回调函数添加到任务队列中,等待执行。
多线程:虽然Node.js是单线程的,但可以使用worker_threads模块来实现多线程并发。worker_threads模块允许你在Node.js中创建多个线程,每个线程可以运行自己的JavaScript代码。这对于执行CPU密集型任务非常有用。
const { Worker } = require('worker_threads'); const worker = new Worker('./worker.js'); worker.on('message', (result) => { console.log(result); }); worker.postMessage('Hello, worker!');
const cluster = require('cluster'); const http = require('http'); const numCPUs = require('os').cpus().length; if (cluster.isMaster) { console.log(`Master ${process.pid} is running`); for (let i = 0; i < numCPUs; i++) { cluster.fork(); } cluster.on('exit', (worker, code, signal) => { console.log(`worker ${worker.process.pid} died`); }); } else { http.createServer((req, res) => { res.writeHead(200); res.end('hello world\n'); }).listen(8000); console.log(`Worker ${process.pid} started`); }
通过结合这些方法,Node.js可以在Linux环境中实现高效的并发处理。