fix(mutex): correct isLocked value

Author: HugoMendes98

src/mutex/mutex.spec.ts

@@ -39,14 +39,17 @@ describe("Mutex", () => {
 					expect(mutex.isLocked).toBeTrue();
 					expect(mutex.queueLength).toBe(1);
 					mutex.unlock();
-					expect(mutex.isLocked).toBeFalse();
+					expect(mutex.isLocked).toBeTrue();
 					expect(mutex.queueLength).toBe(0);
 				}, delay);
 
 				// Will wait until the end of the `setTimeout`
 				await mutex.lock();
 			});
 
+			mutex.unlock();
+			expect(mutex.isLocked).toBeFalse();
+
 			expect(elapsed).toBeGreaterThanOrEqual(delay - offset);
 			expect(elapsed).toBeLessThanOrEqual(delay + offset);
 		});
@@ -81,7 +84,7 @@ describe("Mutex", () => {
 				expect(mutex.isLocked).toBeTrue();
 				expect(mutex.queueLength).toBe(1);
 				mutex.unlock();
-				expect(mutex.isLocked).toBeFalse();
+				expect(mutex.isLocked).toBeTrue();
 				expect(mutex.queueLength).toBe(0);
 			}, max);
 
@@ -108,6 +111,7 @@ describe("Mutex", () => {
 			expect(elapsed).toBeGreaterThanOrEqual(max - offset);
 			expect(elapsed).toBeLessThanOrEqual(max + offset);
 
+			mutex.unlock();
 			expect(mutex.isLocked).toBeFalse();
 			expect(mutex.queueLength).toBe(0);
 		});
@@ -144,6 +148,8 @@ describe("Mutex", () => {
 				ConcurrencyExceedTimeoutException
 			);
 
+			mutex.unlock();
+
 			// The queue is reset, since the `tryAcquire` failed
 			expect(mutex.queueLength).toBe(0);
 			expect(mutex.isLocked).toBeFalse();

src/mutex/mutex.ts

@@ -18,7 +18,7 @@ export class Mutex implements Synchronizer {
 	 * @returns if the current mutex is currently locked
 	 */
 	public get isLocked(): boolean {
-		return this.queueLength !== 0;
+		return this.semaphore.permitsAvailable === 0;
 	}
 
 	/**