const utils = require('./utils');

class Cond {

  constructor() {
    this.waitList = [];
  }

  async wait(timeout) {
    return new Promise((resolve) => {
      const waiterIdx = this.waitList.length;
      this.waitList.push({
        'resolve': resolve,
        'timer': setTimeout(() => {
          if (waiterIdx < this.waitList.length &&
              this.waitList[waiterIdx]['resolve'] == resolve) {
            this.waitList = this.waitList.splice(waiterIdx, 1);
          } else {
            utils.throwError('cond waiterIdx error');
          }
          resolve();
        }, timeout)
      });
    });
  }

  notifyAll() {
    if (this.waitList.length > 0) {
      const waitListCopy = this.waitList;
      this.waitList = [];
      waitListCopy.forEach((v) => {
        clearTimeout(v['timer']);
        v['resolve']();
      });
    }
  }

};

exports.Cond = Cond;