zoukankan      html  css  js  c++  java
  • ES6原生Promise的所有方法介绍(附一道应用场景题目)

    JS的ES6已经出来很久了,作为前端工程师如果对此还不熟悉有点说不过去。不过如果要问,Promise原生的api一共有哪几个?好像真的可以难倒一票人,包括我自己也忽略了其中一个不常用的API Promise.race。我们来瞧一下MDN对Promise的讲解: https://developer.mozilla.org/en-US/docs/Web/JavaScript/Reference/Global_Objects/Promise

    来看一下Promise的方法和prototype列表:

    【1】Promise.prototype.catch 在Promise被reject的时候触发

    【2】Promise.prototype.then 在Promise被resolve的时候触发

    【3】Promise.prototype.finally 无论Promise是否resolve还是reject,都会触发。请注意,这个是一个比较新的特性,大部分浏览器并没有实现该特性。Promise.prototype.finally目前的浏览器兼容性列表如下:

    该特性还在Stage 3阶段,等到在浏览器中大面积普及,估计要很久以后了。可以采用第三方库的实现,比如bluebird。

    【4】Promise.resolve 直接返回一个已经resolve的Promise实例

    【5】Promise.reject 直接返回一个已经reject的Promise实例

    【6】Promise.all 传入一个Promise列表(常见的是由Promise组成的数组),只有当列表中所有的Promise都resolve时,该Promise才会resolve,只要有一个reject,则该Promise会reject。

    【7】Promise.race 传入一个Promise列表,其中第一个resolve的Promise会使得该Promise.race 最终 resolve,如果第一个完成的Promise是reject的,那么Promise.race最终也reject(其实就是和跑的最快的那个Promise结果一样~)。

    其实Promise的原生API也就这么几个,其中Promise.all和Promise.race是最容易被忽略的两个。我之前曾经不太熟悉Promise.race这个API导致实现一个需求卡住了很久。我们来通过一个小的练习熟悉该API的用法吧。

    附上一道题目:

    假设目前有1000个url下载链接,已经存储在数组url[1000]中(即url = ['http://example.com/video1.mp3', ...., 'http://example.com/video1000.mp3']),而且已经有一个函数function download,输入一个url链接,返回一个Promise,该Promise在链接下载完成的时候resolve,下载失败则reject。但是我们要求,任意时刻,同时下载的链接数量不可以超过10个。请写一段代码实现这个需求,要求尽可能快速地将该1000个链接下载完成。

    思路:声明一个长度为10的,由Promise组成的数组,用Promise.race做汇总,只要检测到1个Promise resolve了,那就赶紧把那个Promise替换成一个新的再继续下载。

    const TotalTaskCount = 1000; // 一共有1000个链接
    const MaxConcurrency = 10; // 同时下载的链接数最大不超过10
    const url = [...]; // 1000个下载链接组成的数组
    const download = function (urlStr) {
      // 返回Promise, 当下载完成的时候resolve
    }
    
    Answer:
    
    let todoList = [];
    let nextIndex = 0;
    for (let j = 0; j < MaxConcurrency; j++) {
      let task = download(url[nextIndex]).then(() => {return j}); // 注意这里resolve的值是任务在todoList的脚标,方便我们在Promise.race之后找到完成的任务脚标
      todoList.push(task);
      nextIndex++;
    }
    
    const run = async function(todo) {
      let index = await Promise.race(todo); // 这里index等于Promise.race第一个完成的任务的脚标
      if (nextIndex < TotalTaskCount) {
        todo[index] = download(url[nextIndex]).then(() => {return index;}); // 一旦有一个任务完成,马上把他替换成一个新的任务,继续下载
        nextIndex++;
      }
      await run(todo);
    }
    
    run(todoList);
  • 相关阅读:
    java中的String.format使用
    白话解析平安笔试题:多线程交替打印
    centos7 yum install redis
    CentOS7 linux下yum安装redis以及使用
    开源规则流引擎实践
    java中System.err.print和System.out.print区别
    drools -规则语法
    小明历险记:规则引擎drools教程一
    规则引擎drools封装
    C#中Encoding.Unicode与Encoding.UTF8的区别
  • 原文地址:https://www.cnblogs.com/xuning/p/8045946.html
Copyright © 2011-2022 走看看