Update make-mutex.ts

This commit is contained in:
Alan Mosko
2023-01-17 11:49:49 -03:00
parent 05dd53e2ce
commit 0d53fbe7fa

View File

@@ -1,7 +1,3 @@
import logger from './logger'
const MUTEX_TIMEOUT_MS = 60_000
export const makeMutex = () => {
let task = Promise.resolve() as Promise<any>
@@ -10,11 +6,6 @@ export const makeMutex = () => {
return {
mutex<T>(code: () => Promise<T> | T): Promise<T> {
task = (async() => {
const stack = new Error('mutex start').stack
let waitOver = false
taskTimeout = setTimeout(() => {
logger.warn({ stack, waitOver }, 'possible mutex deadlock')
}, MUTEX_TIMEOUT_MS)
// wait for the previous task to complete
// if there is an error, we swallow so as to not block the queue
try {
@@ -50,4 +41,4 @@ export const makeKeyedMutex = () => {
return map[key].mutex(task)
}
}
}
}