Javascript后台循环

Question

假设我们有一个loop.js 文件：

longLoop().then(res => console.log('loop result processing started'))
console.log('read file started')
require('fs').readFile(__filename, () => console.log('file processing started'))
setTimeout(() => console.log('timer fires'), 500)

async function longLoop () {
  console.log('loop started')
  let res = 0
  for (let i = 0; i < 1e7; i++) {
    res += Math.sin(i) // arbitrary computation heavy operation
    if (i % 1e5 === 0) await null /* solution: await new Promise(resolve => setImmediate(resolve)) */
  }
  console.log('loop finished')
  return res
}

如果运行 (node loop.js) 输出：

loop started
read file started
loop finished
loop result processing started
timer fires
file processing started

如何在循环在后台运行时重写此代码以读取和处理文件？

我的解决方案

我想出的是这样的：

longLoop().then(res => console.log('loop result processing started'))
console.log('read file started')
require('fs').readFile(__filename, () => console.log('file processing started'))
setTimeout(() => console.log('timer fires'), 500)

async function longLoop () {
  let res = 0
  let from = 0
  let step = 1e5
  let numIterations = 1e7
  function doIterations() {
    //console.log(from)
    return new Promise(resolve => {
      setImmediate(() => { // or setTimeout
        for (let i = from; (i < from + step) && (i < numIterations); i++) {
          res += Math.sin(i)
        }
        resolve()
      })
    })
  }
  console.log('loop started')
  while (from < numIterations) {
    await doIterations()
    from += step
  }
  console.log('loop finished')
  return res
}

确实记录了：

loop started
read file started
file processing started
timer fires
loop finished
loop result processing started

有没有更简单、更简洁的方法来做到这一点？我的解决方案有什么缺点？

Answer 1

第一个版本的代码阻止进一步处理的原因是await 得到一个立即解析的承诺（值null 被包装在一个承诺中，就像你做了await Promise.resolve(null) 一样）。这意味着await 之后的代码将在当前“任务”期间恢复：它只是在任务队列中推送一个微任务，该微任务将在同一个任务中被消耗。您待处理的所有其他异步内容都在任务队列中等待，而不是在微任务队列中。

setTimeout 是这种情况，readFile 也是如此。它们的回调在任务队列中等待处理，因此不会优先于awaits 生成的微任务。

所以你需要一种方法让await 将某些东西放入任务队列而不是微任务队列。你可以通过向它提供一个不会立即解决的承诺来做到这一点，但只会在当前任务之后解决。

您可以使用 ....setTimeout:

const slowResolve = val => new Promise(resolve => setTimeout(resolve.bind(null, val), 0));

您可以使用await 调用该函数。这里是一个使用图片加载而不是文件加载的sn-p，但是原理是一样的：

const slowResolve = val => new Promise(resolve => setTimeout(resolve.bind(null, val), 0));

longLoop().then(res => 
    console.log('loop result processing started'))

console.log('read file started')

fs.onload = () => 
    console.log('file processing started');
fs.src = "https://images.pexels.com/photos/34950/pexels-photo.jpg?h=350&auto=compress&cs=tinysrgb";

setTimeout(() => console.log('timer fires'), 500)

async function longLoop () {
  console.log('loop started')
  let res = 0
  for (let i = 0; i < 1e7; i++) {
    res += Math.sin(i) // arbitrary computation heavy operation
    if (i % 1e5 === 0) await slowResolve(i);
  }
  console.log('loop finished')
  return res
}

<img id="fs" src="">