typescript - 打字稿中的进程池

Question

我正在尝试实现一个调度程序，它将在 AWS SQS 上执行长轮询，然后将任何消息调度（负载平衡）到将并行运行的 n 个承诺。如果我有超过 n 个正在运行的承诺，我想停止发送消息（为此我使用 AsyncGenerator），并且我想在我的任何承诺池完成后立即发送消息。

我认为我需要某种阻塞队列（例如具有最大大小和背压的缓冲区），当我的工作人员正在为该缓冲区获取元素来处理它们时，它将由我的生成器提供。

请注意，顺序无关紧要。

我怎样才能实现这两个进程，以便它们可以同时运行？

如果我不清楚，请告诉我，我会尽力详细说明您的问题。

标签： typescriptconcurrency

Answer 1

我如何实现这两个进程，以便它们可以同时运行

您可以使用内置child_process模块生成子进程以同时执行任务。

更多的

具体示例在文档中：https ://nodejs.org/api/child_process.html#child_process_child_process_spawn_command_args_options