Comment exécuter une tâche asynchrone avec socket.io et node.js?

Question

Lorsque je reçois un événement "on" côté serveur, je souhaite démarrer une tâche en parallèle afin de ne pas bloquer le thread de boucle d'événement en cours. Est-il possible de le faire? Comment?

Je ne veux pas bloquer la boucle côté serveur et je veux être en mesure de renvoyer un message au client une fois la tâche terminée, quelque chose comme:

client.on('execute-parallel-task', function(msg) { 
    setTimeout(function() { 
     // do something that takes a while 
     client.emit('finished-that-task'); 
    },0); 
    // this block should return asap, not waiting for the previous call 
}); 

Je ne suis pas sûr si setTimeout fera le travail.

Answer 1

Vous n'avez pas besoin de setTimeout. Votre fonction (msg) sera appelée une fois la tâche d'exécution parallèle terminée.

si vous concevez une tâche à exécuter de manière asynchrone, vous pouvez regarder quelque chose comme le async lib pour Node.js

Async Node JS Link

Answer 2

Il dépend de ce que l'prend un certain temps est. S'il prend un certain temps de manière asynchrone (vous pouvez dire parce que vous devrez enregistrer un rappel ou gestionnaire complete), et prend un certain temps parce qu'il est bloqué sur quelque chose comme IO, plutôt que lié au processeur, il sera intrinsèquement parallèle.

Si cependant, est quelque chose lié synchrone ou CPU, alors que vous pouvez utiliser setTimeout, etc. setImmediate pour renvoyer un message immédiatement, une fois que le gestionnaire pour setTimeout ou setImmediate exécute, votre seul thread d'exécution sera bloqué la manipulation que; vous n'êtes pas vraiment la fixation le problème, simplement le report.

Pour afficher un comportement parallèle réel, vous devez lancer un child process. Vous pouvez utiliser la fonctionnalité de transmission de message pour informer votre opérateur du travail à effectuer et pour notifier le processus parent une fois le travail terminé.

var cp = require('child_process'); 
var child = cp.fork(__dirname + '/my-child-worker.js'); 

n.on('message', function(m) { 
    if (m === "done") { 
     // Whey! 
    } 
}); 

n.send(/* Job id, or something */); 

Puis dans my-child-worker.js;

process.on('message', function (m) { 
    switch (m) { 
     case 'get-x': 
      // blah 
     break; 
     // other jobs 
    } 

    process.send('done'); 
});