Nodejs Async的简化版 实现异步任务的并行或顺序执行

Node.js Async的简化版 实现异步任务的并行或顺序执行

在Node.js中，处理异步操作是一个常见的需求。async库提供了一些方便的工具来管理异步任务的并行或顺序执行。本文将通过一个简单的例子来展示如何使用async库来实现这些功能。

安装 async 库

首先，你需要安装async库。你可以使用npm来安装：

npm install async

并行执行异步任务

假设我们有多个异步任务需要并行执行，并且我们需要等待所有任务完成后再进行下一步操作。我们可以使用async.parallel来实现这一点。

const async = require('async');

// 定义一些异步任务
const tasks = [
    function(callback) {
        setTimeout(() => {
            console.log('Task 1 completed');
            callback(null, 'Result from Task 1');
        }, 2000);
    },
    function(callback) {
        setTimeout(() => {
            console.log('Task 2 completed');
            callback(null, 'Result from Task 2');
        }, 1000);
    }
];

// 使用 async.parallel 执行任务
async.parallel(tasks, (err, results) => {
    if (err) throw err;
    console.log('All tasks completed:', results);
});

在这个例子中，我们定义了两个异步任务，并使用setTimeout模拟异步操作。async.parallel会并行执行这两个任务，并在所有任务完成后调用回调函数，输出结果。

顺序执行异步任务

如果我们希望按顺序执行这些任务，并且前一个任务的结果可以传递给下一个任务，我们可以使用async.waterfall。

const async = require('async');

// 定义一些异步任务
const tasks = [
    function(callback) {
        setTimeout(() => {
            console.log('Task 1 completed');
            callback(null, 'Result from Task 1', 'Extra data');
        }, 2000);
    },
    function(resultFromTask1, extraData, callback) {
        setTimeout(() => {
            console.log('Task 2 completed with data:', resultFromTask1, extraData);
            callback(null, 'Result from Task 2');
        }, 1000);
    }
];

// 使用 async.waterfall 执行任务
async.waterfall(tasks, (err, result) => {
    if (err) throw err;
    console.log('Final result:', result);
});

在这个例子中，async.waterfall会依次执行每个任务，并将前一个任务的结果传递给下一个任务。最终的结果会在最后一个任务完成后输出。

总结

通过使用async库中的parallel和waterfall方法，我们可以轻松地管理异步任务的并行或顺序执行。这使得编写复杂的异步逻辑变得更加简单和直观。