问题标签 [worker-pool]

我正在尝试创建一个工作池，其中一个函数获取网站上的某些数据。但我似乎无法从获取中得到任何东西。

还有另一种获取方式吗？还是我做错了什么？

这是我的代码：

运行脚本.js

myWorker.js

是否可以重用流？我有一个工人池，每个工人都有自己的标准输入，我通过管道向它传输数据。在工作人员内部，我从标准输入读取数据。问题是当我想再次使用同一个工人时，我无法再次写入其标准输入（错误：结束后写入）。有谁知道如何解决它？

作为一个 go 和一般编程的初学者，我一直在用 gopacket 库编写一个端口扫描器，大部分代码已经完成，但是我遇到了一个问题，即生成太多 goroutine 并获得“读取 ip4” 0.0.0.0: i/o timeout' 我做了一些研究，似乎我需要实现一个工作池 我一直在尝试实现这个示例 'https://gobyexample.com/worker-pools'我仍在学习 goroutines 和通道我已经学习了几天，似乎无法弄清楚如何在我的程序中正确实现上述示例，你们能给我一些指示，或者最好是一个代码修复示例。

我正在研究 Node JS 如何提高多个并发请求的性能！在阅读了几个博客后，我发现：

1. 当任何请求到来时，都会触发一个事件，并将相应的回调函数放入事件队列中。
2. 一个事件循环（主线程）负责处理事件队列中的所有请求。如果请求使用非阻塞 I/O，事件循环处理请求并发回响应。
3. 如果请求包含阻塞 I/O 事件循环在内部将此请求分配给工作池中的空闲工作人员，并且当工作人员发回结果时，事件循环发送响应。

我的问题是由于事件循环使用 libuv 库在内部将繁重的阻塞工作传递给工作池，为什么我们需要异步回调？

为了更好地理解，请参阅以下代码：

我使用 apache 基准测试工具检查了两个端点的性能，假设每个 I/O 操作需要 80 毫秒。

令人惊讶的是，具有异步回调的端点每秒的请求数更高。

那么事件循环、线程池和异步等待如何在内部工作以处理更多并发请求呢？

在下面的代码中，我不明白为什么“Worker”方法似乎退出而不是从输入通道“in”中提取值并处理它们。

我曾假设他们只会在消耗来自输入通道“in”的所有输入并处理它们之后才会返回

输出是

我在节点 js 中使用sails 的MVC 结构，没有多线程，它工作得很好。但由于 CPU 密集型任务，我想在我的节点 js 服务器（workerpool）中实现多线程。当尝试使用工作人员运行相同的功能时，它给出的错误是sails is not defined？知道如何解决这个问题吗？

我有一些 Python 脚本用于对数据库进行查询，然后将这些数据提供给对 REST API 端点进行 http 调用的工作人员池。我想尝试将这些作为 Azure 函数应用程序运行，但要做到这一点，我需要将所有内容都放在一个函数中。这是我当前脚本的简化示例：

但我需要在这样的函数中运行它：

我立即遇到的问题是如果name == ' main ' 处理不进入：我打印name并且它是“ app ”。加上函数名：" app .myfunction

如果我使用name == " app .myfunction" 代替，我可以得到处理输入，但这当然会导致问题，当它到达池对象时，我会收到错误 "ModuleNotFoundError: No module named ' app '"。

有没有办法在这样的 Azure Function App 中使用池化，还是我需要重新考虑整个方法？

我有使用 Yarn 和 Mocha 运行的 TypeScript 测试，它们在本地运行良好。然而，当我通过 CircleCI 部署时，我得到了这个：

我已经xdescribe完成了所有测试，但仍然会发生这种情况。想法赞赏。