nodejs中简单实现Javascript Promise机制的实例

下面是“nodejs中简单实现JavaScript Promise机制的实例”的完整攻略。

Promise机制简介

Promise是一种异步编程模型，它可以让我们更加优雅地处理异步的操作，避免回调函数嵌套带来的代码臃肿和难以维护的问题。

Promise有三种状态：

• pending（进行中）
• fulfilled（已成功）
• rejected（已失败）

Promise有两个重要的方法：

• .then()：当Promise状态从pending变为fulfilled时会调用；
• .catch()：当Promise状态从pending变为rejected时会调用。

Promise的实现

下面是一个简单的Promise实现，它包含了三种状态和两个方法：

class Promise {
  constructor(executor) {
    this.state = 'pending';
    this.value = undefined;
    this.reason = undefined;
    this.onFulfilledCallbacks = [];
    this.onRejectedCallbacks = [];

    const resolve = (value) => {
      if (this.state === 'pending') {
        this.state = 'fulfilled';
        this.value = value;
        this.onFulfilledCallbacks.forEach(fn => {
          fn();
        })
      }
    }

    const reject = (reason) => {
      if (this.state === 'pending') {
        this.state = 'rejected';
        this.reason = reason;
        this.onRejectedCallbacks.forEach(fn => {
          fn();
        })
      }
    }

    try {
      executor(resolve, reject);
    } catch (error) {
      reject(error)
    }
  }

  then(onFulfilled, onRejected) {
    if (this.state === 'fulfilled') {
      onFulfilled(this.value);
    }

    if (this.state === 'rejected') {
      onRejected(this.reason);
    }

    if (this.state === 'pending') {
      this.onFulfilledCallbacks.push(() => {
        onFulfilled(this.value);
      })

      this.onRejectedCallbacks.push(() => {
        onRejected(this.reason);
      })
    }
  }

  catch(onRejected) {
    if (this.state === 'rejected') {
      onRejected(this.reason);
    }

    if (this.state === 'pending') {
      this.onRejectedCallbacks.push(() => {
        onRejected(this.reason);
      })
    }
  }
}

Promise的使用

下面是两个示例，分别演示了如何使用Promise。

示例一

function asyncFunction() {
  const promise = new Promise((resolve, reject) => {
    setTimeout(() => {
      resolve('Hello, World!');
    }, 1000);
  });

  return promise;
}

asyncFunction()
  .then((result) => {
    console.log(result);
  })
  .catch((error) => {
    console.error(error);
  })

这个示例实现了一个异步函数asyncFunction，它会在1秒后返回一个值。在使用asyncFunction时，我们传入了一个回调函数作为参数，这个回调函数会在Promise状态变为fulfilled时被调用。如果Promise状态变为rejected，我们也可以使用.catch()方法来捕获错误。

示例二

function asyncFunction() {
  const promise = new Promise((resolve, reject) => {
    setTimeout(() => {
      reject(new Error('Something went wrong!'));
    }, 1000);
  });

  return promise;
}

asyncFunction()
  .then((result) => {
    console.log(result);
  })
  .catch((error) => {
    console.error(error);
  })

这个示例实现了一个异步函数asyncFunction，它会在1秒后抛出一个错误。在使用asyncFunction时，我们同样传入了一个回调函数作为参数，这个回调函数会在Promise状态变为rejected时被调用。

总结

Promise是一种用于异步编程的模型，它可以让我们更加优雅地处理异步的操作。在实践中，我们通常会使用Promise来代替回调函数来处理异步操作。由于Promise的实现方式比较固定，它会比回调函数更加可读和易于维护。