这道题的考察点：

发布订阅
实现异步串行
链式调用

解题思路：

用一个数组，先收集每次调用task的函数
当调用start方法，再去遍历这个数组，执行数组的每一个task函数
执行函数的时候，需要考虑异步串行，因为是一个延迟函数，肯定是一个异步的，并且下一个异步必须等待上一个异步完成之后才能执行。

function sleep(delay, callback) {
  return new Promise((resolve, reject) => {
    setTimeout(() => {
      callback();
      resolve()
    }, delay);
  })
}
class Queue {
  constructor() {
    this.listenser = [];
  }
  task(delay, callback) {
    // 收集函数
    this.listenser.push(() => sleep(delay, callback));
    return this;
  }
  async start() {
    // 遍历函数
    for (let l of this.listenser) {
      await l()
    }
  }
}

new Queue()
.task(1000,()=>console.log(1))
.task(2000,()=>console.log(2))
.task(3000,()=>console.log(3)).start();

promise异步串行的方案还可以reduce来实现，start函数可以改成如下：

  start() {
    this.listenser.reduce((acc, cur) => {
      return acc.then(() => cur());
    }, Promise.resolve());
  }

9. 实现一个Queue类 #9

Description

Metadata

Metadata

Assignees

Labels

Projects

Milestone

Relationships

Development

Issue actions