(使用 Sails.js)

我正在为 Node 上长时间运行的进程测试 webworker-threads (https://www.npmjs.com/package/webworker-threads)，以下示例看起来不错:

var Worker = require('webworker-threads').Worker;
var fibo = new Worker(function() {
    function fibo (n) {
        return n > 1 ? fibo(n - 1) + fibo(n - 2) : 1;
    }
    this.onmessage = function (event) {
        try{
            postMessage(fibo(event.data));                

        }catch (e){
            console.log(e);                
        }
    }
});
fibo.onmessage = function (event) {
    //my return callback
};
fibo.postMessage(40);

但是，只要我添加任何代码来查询 Mongodb，它就会引发异常: (在查询中没有使用 Sails 模型，只是为了确保代码可以自己运行——db 没有密码)

var Worker = require('webworker-threads').Worker;
var fibo = new Worker(function() {
    function fibo (n) {
        return n > 1 ? fibo(n - 1) + fibo(n - 2) : 1;
    }
    // MY DB TEST -- THIS WORKS FINE OUTSIDE THE WORKER
    function callDb(event){
        var db = require('monk')('localhost/mydb');
        var users = db.get('users');
        users.find({ "firstName" : "John"}, function (err, docs){
            console.log(("serviceSuccess"));
            return fibo(event.data);
        });
    }
    this.onmessage = function (event) {
        try{

            postMessage(callDb(event.data));     // calling db function now           

        }catch (e){
            console.log(e);                
        }
    }
});
fibo.onmessage = function (event) {
    //my return callback
};
fibo.postMessage(40);

由于 DB 代码在 Worker 之外工作得非常好，我认为它与 require 有关。我尝试了一些在 Worker 之外也可以使用的方法，比如

 var moment = require("moment");
 var deadline = moment().add(30, "s");

而且代码也抛出异常。不幸的是，console.log 只显示所有类型的错误:

{Object}
{/Object}

所以，问题是:在 Worker 中使用 require 是否有任何限制或指南？我在这里做错了什么？

更新

似乎线程不允许外部模块 https://github.com/xk/node-threads-a-gogo/issues/22

TL:DR I think that if you need to require, you should use a node's cluster or child process. If you want to offload some cpu busy work, you should use tagg and the load function to grab any helpers you need.

在阅读了这个帖子后，我发现这个问题与这个问题相似: Load Nodejs Module into A Web Worker

webworker-threads 的作者 Audreyt 回答说:

author of webworker-threads here. Thank you for using the module!

There is a default native_fs_ object with the readFileSync you can use to read files.

Beyond that, I've mostly relied on onejs to compile all required modules in package.json into a single JS file for importScripts to use, just like one would do when deploying to a client-side web worker environment. (There are also many alternatives to onejs -- browserify, etc.)

Hope this helps!

所以看来 importScripts 是要走的路。但是在这一点上，对于我想做的事情来说可能太hacky了，所以可能 KUE 是一个更成熟的解决方案。

最佳答案

我是 node-webworker-threads 的合作者项目。

node-webworker-threads

您的更新是正确的:node-webworker-threads 不(当前)支持 requireing 外部模块。

它对某些内置函数的支持有限，包括文件系统调用和 console.log 版本。如您所见，在 node-webworker-threads 中实现的 console.log 的版本与内置的 console.log 不同> 在 Node.js 中；例如，它不会自动对 Object 的组件进行漂亮的字符串表示。

在某些情况下，您可以使用外部模块，正如 audreyt 在她的回复中所述。显然这并不理想，我将不完整的 require 视为 node-webworker-threads 的主要“破坏者”。我希望今年夏天能继续努力。

何时使用 node-webworker-threads

node-webworker-threads 允许您针对 WebWorker API 编写代码并在客户端(浏览器)和服务器(Node.js)中运行相同的代码。这就是为什么你会使用 node-webworker-threads 而不是 node-threads-a-gogo .

node-webworker-threads 如果你想要最轻量级的基于 JavaScript 的工作线程来做一些 CPU 密集型的事情，那就太好了。示例:素数、斐波那契、蒙特卡罗模拟、卸载内置但可能成本高昂的操作，如正则表达式匹配。

当不使用node-webworker-threads

node-webworker-threads 强调可移植性而非便利性。对于仅 Node.js 的解决方案，这意味着 node-webworker-threads 不是要走的路。

如果您愿意在全栈可移植性方面做出妥协，有两种方法可以走:速度和便利性。

对于速度，请尝试 C++ add-on .使用NaN .我推荐 Scott Frees 的 C++ and Node.js Integration书来学习如何做到这一点，它会为你节省很多时间。你需要为你的 C++ 技能复习付出代价，如果你想使用 MongoDB，那么这可能不是一个好主意。

为了方便，请使用 Child Process基于 worker 池，如 fork-pool .在这种情况下，每个 worker 都是一个成熟的 Node.js 实例。然后，您可以 require 满足您的需求。与 node-webworker-threads 或 C++ 附加组件相比，您需要付出更大的应用程序占用空间和更高的通信成本。

关于node.js - 网络 worker 线程 : is it OK to use "require" inside worker?，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/30949987/