【面试题】基于promise的并发函数的实现

矫情吗；* 2022-12-21 14:53 96阅读 0赞

要求：实现一个 Parallel 函数，可以控制并发任务的数量，实现效果如下

function task (ms, name) { 
      return new Promise((resolve, reject) => { 
        setTimeout(_ => { 
          console.log(new Date(), name);
          resolve();
        }, ms)
      })
    }
    console.log('task start-----------', new Date());
    const para = new Parallel(3);
    // 载入任务
    para.addTask(task, 1000, 'a');
    para.addTask(task, 2000, 'b');
    para.addTask(task, 3000, 'c');
    para.addTask(task, 4000, 'd');
    // 开始执行
    para.start();
    // 并发数量为 3
    // 分别于 1 2 3 5 秒后执行上述任务
    // 并发数量为 2
    // 则分别于 1 2 4 6 秒后执行上述任务

解答：

function task (ms, name) { 
      return new Promise((resolve, reject) => { 
        setTimeout(_ => { 
          console.log(new Date(), name);
          resolve();
        }, ms)
      })
    }
    
    function Parallel (number) { 
      this.number = number;
      this.currentNumber = 0;
      this.taskList = [];
      this.carryTaskList = [];
    }
    Parallel.prototype.addTask = function (task, ms, name) { 
      this.taskList.push({ 
        fn: task,
        ms: ms,
        name: name
      })
    }
    Parallel.prototype.start = function () { 
      if (this.taskList.length <= 0) { 
        return;
      }
      while (this.currentNumber < this.number) { 
        const newTask = this.taskList.shift();
        this.carryTaskList.push(newTask);
        this.currentNumber++;
      }
      this.carry();
    }
    Parallel.prototype.carry = function () { 
      while (this.carryTaskList.length > 0) { 
        const newTask = this.carryTaskList.shift();
        newTask.fn(newTask.ms, newTask.name).then(_ => { 
          this.currentNumber--;
          this.start();
        })
      }
    }
    
    console.log('task start-----------', new Date());
    const para = new Parallel(3);
    para.addTask(task, 1000, 'a');
    para.addTask(task, 2000, 'b');
    para.addTask(task, 3000, 'c');
    para.addTask(task, 4000, 'd');
    para.start();

发表评论取消回复

表情：

评论列表（有 0 条评论，96人围观）

还没有评论，来说两句吧...

相关阅读

相关 promise-面试题2

//3 7 4 1 2 5 //同步3 7 4 / 宏：[5] 微：[1,2] 最后resolve(6) 返回给p 但是不执行输出了 /

àì夳堔傛蜴生んèń/ 2023年03月02日 07:42/ 0 赞/ 31 阅读

相关 promise-面试题1

//放入宏队列 setTimeout(()=>{ console.log(1) },0)

Dear 丶/ 2023年03月02日 07:42/ 0 赞/ 38 阅读

相关使用Promise.all实现限制并发请求函数

文章目录 Promise.all 的简单解释：需求解释设计思路代码实现 Pr

逃离我推掉我的手/ 2023年01月10日 05:23/ 0 赞/ 208 阅读

相关 web前端高频面试题（promise的精简封装）

var obj = { status:'', value:'' } function Apromise(fn){

客官°小女子只卖身不卖艺/ 2022年12月26日 10:23/ 0 赞/ 161 阅读

相关【面试题】基于promise的并发函数的实现

要求：实现一个 Parallel 函数，可以控制并发任务的数量，实现效果如下 function task (ms, name) { return new

矫情吗；*/ 2022年12月21日 14:53/ 0 赞/ 97 阅读

相关 Promise面试题汇总

本文为基础版，更详细的内容见文章： [「2021」高频前端面试题汇总之代码输出结果篇][2021] 目录本文为基础版，更详细的内容见文章：

小鱼儿/ 2022年11月29日 12:22/ 0 赞/ 245 阅读

相关 Promise面试题整理

具体逻辑原则参考上一篇文章整理： - 面试题一：写出下列代码的打印结果？？ setTimeout(()=>{ console.log(1)

你的名字/ 2022年10月29日 12:29/ 0 赞/ 296 阅读

相关 Promise 对象及相关面试题

> Promise 是异步编程的一种解决方案，比传统的解决方案——回调函数和事件——更合理和更强大。它由社区最早提出和实现，ES6 将其写进了语言标准，统一了用法，原生提供了P

￡神魔★判官ぃ/ 2022年10月06日 02:56/ 0 赞/ 162 阅读

相关 Promise 面试题整理

基础输出题 1. 题目1 const promise = new Promise((resolve, reject) => { consol

ゞ浴缸里的玫瑰/ 2022年08月30日 09:10/ 0 赞/ 221 阅读

相关 Promise面试题之Promise.all和Promise.race的区别

[转载自：][Link 1][https://blog.csdn.net/xyphf/article/details/77925571][https_blog.csdn.net

你的名字/ 2022年02月27日 16:04/ 0 赞/ 358 阅读