Node js异步队列和多线程

Question

我正在使用节点 js 构建一个应用程序，该应用程序必须接受用户的请求，读取 mongodb 并更新特定的用户数据，然后再为该特定用户接受另一个请求。我可以使用带有此代码的异步队列来做到这一点：

//Create a queue with concurrency of 1
var tasksQueue = async.queue(function (userInfo, callback) {
User.verifyAndUpdateAccount(userInfo, callback)
}, 1);

router.post('/', function (req, res, next) {
res.setHeader('Content-Type', 'application/json');
//Is required datas present?
if (!req.body.username || !req.body.password) {
return res.send(null);
}
var username = req.body.username;
var password = req.body.password;
//Verify account informations and update them
tasksQueue.push({username: username, password:password}, function (err,
updatedUser) {

if (err == 'NO_MORE_REQUESTS_ALLOW') {
    // S'il ne lui reste plus de sms
    return res.send({
        code: 400,
        message: 'NO_MORE_REQUESTS_ALLOW'
    })

} else if (err) throw err;

//**********************************************************
//  Build the response here and respond to user requests
})

问题是当我使用模块cluster.js时它不能很好地工作，因为每个线程都有自己的队列并且不关心其他线程。我希望我的应用能够像这样工作：

假设 user1 发出 2 个请求，然后 user2 发出 1 个请求。假设我有 4 个内核，我希望我的第一个线程开始处理 user1 的第一个请求，并且所有线程在处理他的第二个请求之前等待 user1 第一个请求已被处理。但是其他线程必须能够在处理user1第一个请求之前处理user2请求，因为1个请求只更新mongodb中单个用户的数据，不会影响其他人，所以我们不需要等待。

Answer 1

也许您可以优化代码以使响应处理足够快。但是如果你确实需要一种非阻塞方式来进行繁重的计算，你可以试试'napajs'，它是由微软发布的，它可以与 Node.js 一起使用，在同一进程中启用多线程 JavaScript 场景。这是一个quick introduction 供您参考。

您的代码将如下所示：

var napa = require('napajs');

// One-time setup. 
// You can change number of workers per your requirement. 
var zone = napa.zone.create('response-builders', { workers: 4 });

function serveRequest() {
    var request = null; 

    // Get request from queue.
    // ...

    zone.execute(() => {
        // Build the response here
        return response;
    }, [request]).then((result) => {
        // respond to user
        console.log(result.value);
    });
}