mutex-lock-redis/test/mutex.test.ts

import { test } from "bun:test";
import { MutexLock } from "../src/MutexLock";

test(
	"redis mutex",
	async () => {
		const mutexLock = await MutexLock.create();

		const testLock = async () => {
			const release = await mutexLock.obtainLock("test");
			console.log("got lock");
			try {
				await new Promise((res) => setTimeout(res, 3000));
			} finally {
				await release();
				console.log("released lock");
			}
		};

		await Promise.all([testLock(), testLock(), testLock(), testLock()]);
	},
	{
		timeout: Number.POSITIVE_INFINITY,
	},
);