等待异步队列进行（异步模块）

Question

我正在尝试使用 nodejs 和异步模块构建一个队列，但它没有按预期工作。

这是我的代码：

const async = require('async');

const queueSize = 10;
const taskHandler = function (task, done) {
    task(done);
};

const myQueue = async.queue(taskHandler, queueSize);

myQueue.drain = function () {
    console.log('The queue is now empty.');
};

function delay() {
    return new Promise(resolve => setTimeout(resolve, 1000));
}

async function delayedLog(item) {
    await delay();
    console.log(item);
}

const run = async () => {
    for (let item = 0; item < 30; item++) {
        myQueue.push(async function (done) {
            await delayedLog(item)
            done();
        });
    }
}

(async () => {
    console.log('START');
    await run();
    console.log('END);
})()

我想要什么：

START
// logs from delayedLog
END 

输出：

START
END 
// logs from delayedLog

如您所见，等待不起作用。我试图对模块进行承诺，但问题仍然存在。我尝试使用 d3-queue，但遇到了完全相同的问题。

有什么建议吗？

Answer 1

正如@Chiến Nghê 所说，您正在使用一些不需要的异步/等待，但这是另一个问题。

您的 await 最终无法正常工作，因为您的 drain 函数在队列末尾被调用并且它没有返回一个 Promise。

你必须承诺你的功能，这里有一个示例：

function end() {
    return new Promise((resolve, reject) => {
        myQueue.drain = function () {
            console.log('The queue is now empty.');
            resolve();
        };
    })
}

然后你可以在你的结束函数上使用你的异步等待：

(async () => {
    console.log('START');
    run();
    await end();
    console.log('END');
})()

输出：

START
// a lot of logs
END 

Answer 2

您的程序按原样运行。实际上你不需要为函数run() 声明async。该函数只是将 30 个异步任务放入队列以供稍后执行，然后结束。

我不知道你想要什么，但如果你想要 console.log('END') 逻辑只执行队列中的每个异步任务完成。请将其移至队列的drain() 函数。