Method acquire

lib/interfaces/locker.ts:18–38

()

  }

  public async acquire() {
    console.debug('Acquiring lock:', this.lockName);
    let currentLock = locks.get(this.lockName);

    while (currentLock) {
      // Only wait if the lock hasn't expired
      if (currentLock.expiresAt > new Date()) {
        console.debug('Waiting for lock to expire:', this.lockName);
        await wait();
      } else {
        // Release lock since it has expired
        this.release();
      }

      currentLock = locks.get(this.lockName);
    }

    locks.set(this.lockName, {
      expiresAt: new Date(new Date().setMilliseconds(new Date().getMilliseconds() + expirationInMilliseconds)),
    });
  }

  public release() {
    console.debug('Releasing lock:', this.lockName);