0



我有一个快速应用程序，其中我有一个需要 aprox 的生成器函数。5分钟处理大量数据。不幸的是，我无法优化该功能。
Express会在 2 分钟后自动超时，我不想仅针对此特定功能进行更改。我想如果我定期打个res.write()电话，2 分钟规则就不适用了。

我的问题：
如何res.write('Something')在等待另一个函数终止时每 X 秒执行一次？

我希望它执行以下操作，希望您能理解。

    function main() {
      co(function* () {
        const something = yield promise(); // function that needs a lot of time
        const doWhileWaiting = setTimeout(() => {
          if (!something) {
            // Print this while waiting for the value of something
            console.log('Waiting for something ... ');
          } else {
            console.log(something);
            clearInterval(doWhileWaiting);
          }
        }, 5000);
      });
    }
4

2 回答 2

0

您的 api 本身不应该有如此繁重的阻塞功能。更好的是让另一个进程为您处理这种计算，因为节点是单线程的，这将阻止所有其他计算。通过在计算函数中添加超时，肯定有办法在一个线程/进程中做到这一点，但这不是很好的风格。由于我不知道您的功能在做什么，因此很难给出一个可靠的答案，在您的情况下什么是最好的。

正如你所说的它每天执行一次，你可以做一个 cronjob 触发另一个进程。如果您需要与您的 api 进程进行通信，您可能需要查看子进程。https://nodejs.org/api/child_process.html

于 2017-03-20T22:04:12.323 回答
0

这不是很难实现：

const secret = Symbol();
const delay = ms => new Promise(r => setTimeout(() => r(secret), ms));

async waitFor(promise) {
    while(true) {
        const racer = await Promise.race(promise, delay(1));
        if(racer !== secret) return; // our promise won!
        await delay(100);
   }
}

此时，您需要添加一个操作，以便在它尚未完成时运行。

async waitFor(promise, action) {
    while(true) {
        const racer = await Promise.race(promise, delay(1));
        if(racer !== secret) return; // our promise won!
        await action(); // support passing a promise action.
        await delay(100);
   }
}

// will write to `res` every 100 ms while `yourPromise is not resolved.
waitFor(yourPromise, () => res.write("..."));

请注意，从根本上讲，您应该将额外的工作放在工作队列中并使用单独的进程来处理它。Node 真的不适合这种工作负载。我建议查看其他答案以获取替代方案。

于 2017-03-20T22:59:55.980 回答