信号量 - JavaScript

简介

信号量是一种用于管理资源访问和调度的同步机制。在JavaScript中，信号量是一个计数器，每当代码中请求资源时，信号量的值会减少，当值为0时，请求被阻塞，直到资源被释放。

JavaScript中的信号量可以使用Promise和async/await实现。

Promise实现信号量

//创建Promise对象
function createSemaphore(maxCount){
  let count = 0;
  let waitQueue = [];

  function release(){
    count++;
    if(waitQueue.length > 0){
      let resolve = waitQueue.shift();
      resolve();
    }
  }

  return function(){
    return new Promise((resolve, reject)=>{
      if(count < maxCount){
        count++;
        resolve();
      } else {
        waitQueue.push(resolve);
      }
    }).then(release, release);
  };
}

上述代码中，createSemaphore函数返回一个可以创建互斥信号量的函数，这个函数接受一个整数作为参数，表示可以同时访问资源的最大数量。每次调用这个函数，都会返回一个Promise对象，当信号量被获得时，Promise对象会被resolve，并且对应的计数器会减少1。当达到最大并发量时，Promise对象会被添加到等待队列中，直到有空闲资源。

async/await实现信号量

class Semaphore {
  constructor(maxCount) {
    this.maxCount = maxCount;
    this.count = 0;
    this.waitQueue = [];
  }

  async acquire() {
    if (this.count < this.maxCount) {
      this.count++;
    } else {
      await new Promise(resolve => this.waitQueue.push(resolve));
      return this.acquire();
    }
  }

  release() {
    this.count--;
    if (this.waitQueue.length > 0) {
      const resolve = this.waitQueue.shift();
      resolve();
    }
  }
}

上述代码中，Semaphore类封装了信号量的实现，其中acquire方法返回一个Promise对象，即await semaphore.acquire()语句会等待获取资源的结果。当信号量没有达到最大并发量时，acquire会立即返回。否则，将resolve添加到等待队列中，并返回一个新的Promise对象。

总结

信号量是一种同步机制，用于管理资源访问和调度。在JavaScript中，信号量可以使用Promise和async/await实现。Promise实现需要创建等待队列来避免死锁，而async/await实现方式则更为直观。无论哪种方式，信号量都是一个极为有用的工具，可以帮助我们充分利用并发请求。