向NodeJS提出不一致请求(更改虚荣不一致)

const redis = require('redis');
const client = redis.createClient();

async function acquireLock(lockName, timeout) {
  return new Promise((resolve, reject) => {
    client.set(lockName, 'locked', 'EX', timeout, 'NX', (err, reply) => {
      if (err) return reject(err);
      resolve(reply === 'OK');
    });
  });
}

async function releaseLock(lockName) {
  return new Promise((resolve, reject) => {
    client.del(lockName, (err, reply) => {
      if (err) return reject(err);
      resolve(reply);
    });
  });
}

async function performTaskWithLock(lockName, task, timeout = 10) {
  const hasLock = await acquireLock(lockName, timeout);
  if (!hasLock) {
    throw new Error('Failed to acquire lock');
  }
  try {
    await task();
  } finally {
    await releaseLock(lockName);
  }
}

// 示例任务
async function exampleTask() {
  console.log('Performing task...');
  // 模拟任务执行时间
  await new Promise(resolve => setTimeout(resolve, 2000));
  console.log('Task completed');
}

// 使用示例
performTaskWithLock('myLock', exampleTask)
  .then(() => console.log('Task finished'))
  .catch(err => console.error('Error:', err));