node.js 多个异步过程判断执行是否完成

cyrils 发布于2019-08-21 18:00 / 2212人阅读

摘要：方案二判断异步过程执行次数方案方案的判断条件，这里的充当异步任务执行情况的观察员，仅与异步过程的调用次数有关，且与其他处理过程无关。不过应当注意的处理。避免其对最终处理的影响。

场景：想请求量较大的网络数据，比如想获取1000条结果，但数据处理速度慢，有超时的风险，可以分成10次处理，每次处理100条；所有请求完成后再统一进行处理。

这样的应用场景，可以这样处理：

方案一：判断请求到的数据条目

// 模拟网络请求
function fetch(url, callback) {
  setTimeout(function (){
    callback(null, {
        subjects: [{
          data: Math.round(Math.random() * 100)
        }]
      });
  }, 2000);
}

// 实现方案1
function multiTask_1 () {
  var arr = [];
  var baseUrl = "https://api.douban.com/v2/movie/top250";
  for (var start = 0; start < 10; start++) {
    var url = baseUrl + "?start=" + start + "&count=1";
      fetch(url, function(error, res) {
        var data = res.subjects;
        arr = arr.concat(data);
        // 调用完成后统一处理
        if (arr.length === 10) {
          console.log(arr);
        }
    });
  }
}

将运行结果用arr.length来判断，如果arr.length不像我们期望的那样，比如由于网络传输或者处理异常，少一条，那么我们将无法做后续的处理。这种处理方式强业务耦合；不具有普适性。

方案二：判断异步过程执行次数

// 方案2
function multiTask_2 () {
  var taskWatcher = 0;
  var arr = [];
  var baseUrl = "https://api.douban.com/v2/movie/top250";
  for (var start = 0; start < 10; start++) {
    taskWatcher++;
    var url = baseUrl + "?start=" + start + "&count=1";
    fetch(url, function(error, res) {
        var data = res.subjects;
        arr = arr.concat(data);
        taskWatcher--;
        if (taskWatcher === 0) {
          console.log(arr);
        }
    });
  }
}

方案2 的判断条件，这里的 taskWatcher 充当异步任务执行情况的观察员，
仅与异步过程的调用次数有关，且与其他处理过程无关。那有没有其他方案呢

方案三：Promise.all()

Promise.all(iterable) 方法返回一个 Promise, 它将在上述可迭代对象中的所有 Promise 被 resolve 之后被 resolve，或者在任一 Promise 被 reject 后被 reject。

function multiTask_3 () {
  // var taskWatcher = 0;
  var taskStack = [];
  var arr = [];
  var baseUrl = "https://api.douban.com/v2/movie/top250";
  for (var start = 0; start < 10; start++) {
    taskStack.push(
      new Promise((resolve, reject) => {
        var url = baseUrl + "?start=" + start + "&count=1";
        fetch(url, function(error, res) {
          var data = res.subjects;
          arr = arr.concat(data);
          resolve();
        });
      })
    );
  }

  Promise.all(taskStack).then(function () {
    console.log(arr);
  });
}

这种方式更具有通用性，如果异步任务类型不同，也可以用这种方式来解决。不过应当注意reject的处理。避免其对最终处理的影响。

方案四： EventProxy

EventProxy是朴灵写的，https://github.com/JacksonTian/eventproxy

  var ep = new EventProxy();
  var arr = [];
  ep.after("fetchData", 10, function (list) {
    list.forEach(function(item){
      arr = arr.concat(item); 
    });
    console.log(arr);
  });

  var baseUrl = "https://api.douban.com/v2/movie/top250";
  for (var start = 0; start < 10; start++) {
    var url = baseUrl + "?start=" + start + "&count=1";
      fetch(url, function(error, res) {
        var data = res.subjects;
        ep.emit("fetchData", data);
    });
  }

EventProxy基于事件订阅/发布模式，这里的after 方法可以侦听多次事件，回调中保存了多次异步任务的数据结果的数组；除此之外EventProxy还支持多个不同事件的侦听和处理。

云服务器 GPU云服务器判断js加载完成异步执行判断一个js加载完成 js异步延迟执行

文章版权归作者所有，未经允许请勿转载,若此文章存在违规行为，您可以联系管理员删除。

转载请注明本文地址：https://www.ucloud.cn/yun/90324.html

Node_深入浅出Node

摘要：简介项目命名为就是一个服务器单纯开发一个服务器的想法，变成构建网络应用的一个基本框架发展为一个强制不共享任何资源的单线程，单进程系统。单线程弱点无法利用多核错误会引起整个应用退出，应用的健壮性大量计算占用导致无法继续调用异步。 NodeJs简介 Ryan Dahl项目命名为：web.js 就是一个Web服务器.单纯开发一个Web服务器的想法，变成构建网络应用的一个基本框架.Node发展...

shinezejian 2019-08-19 18:48 评论0 收藏0
浏览器与Node的事件循环(Event Loop)有何区别?

摘要：事件触发线程主要负责将准备好的事件交给引擎线程执行。它将不同的任务分配给不同的线程，形成一个事件循环，以异步的方式将任务的执行结果返回给引擎。 Fundebug经作者浪里行舟授权首发，未经同意请勿转载。前言本文我们将会介绍 JS 实现异步的原理，并且了解了在浏览器和 Node 中 Event Loop 其实是不相同的。一、线程与进程 1. 概念我们经常说 JS 是单线程执行的，...

TANKING 2019-08-23 14:43 评论0 收藏0
Node.js 异步异闻录

摘要：的异步完成整个异步环节的有事件循环观察者请求对象以及线程池。执行回调组装好请求对象送入线程池等待执行，实际上是完成了异步的第一部分，回调通知是第二部分。异步编程是首个将异步大规模带到应用层面的平台。 showImg(https://segmentfault.com/img/remote/1460000011303472); 本文首发在个人博客：http://muyunyun.cn/po...

zzbo 2019-08-21 16:40 评论0 收藏0
Nodejs高性能原理(上) --- 异步非阻塞事件驱动模型

摘要：使用了一个事件驱动非阻塞式的模型，使其轻量又高效。的包管理器，是全球最大的开源库生态系统。按照这个定义，之前所述的阻塞，非阻塞，多路复用信号驱动都属于同步。系列文章 Nodejs高性能原理(上) --- 异步非阻塞事件驱动模型Nodejs高性能原理(下) --- 事件循环详解前言终于开始我nodejs的博客生涯了,先从基本的原理讲起.以前写过一篇浏览器执行机制的文章,和nodej...

yy736044583 2019-08-26 10:42 评论0 收藏0
webpack原理

摘要：原理查看所有文档页面前端开发文档，获取更多信息。初始化阶段事件名解释初始化参数从配置文件和语句中读取与合并参数，得出最终的参数。以上处理的相关配置如下编写编写的职责由上面的例子可以看出一个的职责是单一的，只需要完成一种转换。 webpack原理查看所有文档页面：前端开发文档，获取更多信息。原文链接：webpack原理，原文广告模态框遮挡，阅读体验不好，所以整理成本文，方便查找。工作...

trigkit4 2019-08-26 11:55 评论0 收藏0