lock2.ts

import { setTimeout } from 'node:timers/promises';
import { createClient } from 'redis';
import { RLock } from '../src';

const client = createClient();
const rlock = RLock.node(client);

async function main() {
	await client.connect();
	const lock1 = await rlock.lock(['k1', 'k2']);
	const lock2 = await rlock.lock(['k1', 'k3']);
	const lock3 = await rlock.lock(['k2', 'k3']);
	const ttl = 200;

	console.log(`Lock1: lock => ${await lock1.lock(ttl)}`);
	console.log(`Lock2: lock => ${await lock2.lock(ttl)}`);
	console.log(`Lock3: lock => ${await lock3.lock(ttl)}`);
	await setTimeout(ttl);
	console.log(`Timeout: ${ttl}`);

	console.log(`Lock2: lock => ${await lock2.lock(ttl)}`);
	console.log(`Lock3: lock => ${await lock3.lock(ttl)}`);
	console.log(`Lock1: lock => ${await lock1.lock(ttl)}`);
	await setTimeout(ttl);
	console.log(`Timeout: ${ttl}`);

	console.log(`Lock3: lock => ${await lock3.lock(ttl)}`);
	console.log(`Lock1: lock => ${await lock1.lock(ttl)}`);
	console.log(`Lock2: lock => ${await lock2.lock(ttl)}`);
	// Output:
	// Lock1: lock => true
	// Lock2: lock => false
	// Lock3: lock => false
	// Timeout: 200
	// Lock2: lock => true
	// Lock3: lock => false
	// Lock1: lock => false
	// Timeout: 200
	// Lock3: lock => true
	// Lock1: lock => false
	// Lock2: lock => false
}

main().catch(console.error).finally(() => client.quit());