Function execWithMutexId

panel/src/app/utils/sync.ts:21–34

(id: string, fn: () => Promise<T>)

}

export async function execWithMutexId<T>(id: string, fn: () => Promise<T>) {
  let mutex = mutexIdMap.get(id);
  if (!mutex) {
    mutex = new Mutex();
    mutexIdMap.set(id, mutex);
  }
  const releaseLock = await mutex.acquire();
  try {
    return await fn();
  } finally {
    releaseLock();
    mutexIdMap.delete(id);
  }
}