0ct0pu5/ente
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Inline

Browse source
This commit is contained in:
Manav Rathi 2024-04-05 09:13:15 +05:30
parent a68dce35f6
commit 2c098904fb
No known key found for this signature in database
1 changed files with 8 additions and 12 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

20
web/packages/shared/utils/queueProcessor.ts
View file

@ -18,9 +18,7 @@ export interface CancellationStatus {
export default class QueueProcessor<T> {
private requestQueue: RequestQueueItem[] = [];
private requestInProcessing = 0;
private maxParallelProcesses = 1;
private isProcessingRequest = false;
public queueUpRequest(
request: (canceller?: RequestCanceller) => Promise<T>,
@ -40,20 +38,17 @@ export default class QueueProcessor<T> {
isCanceled,
canceller,
});
this.pollQueue();
this.processQueueIfNeeded();
});
return { promise, canceller };
}
private async pollQueue() {
if (this.requestInProcessing < this.maxParallelProcesses) {
this.requestInProcessing++;
this.processQueue();
}
}
private async processQueueIfNeeded() {
if (this.isProcessingRequest) return;
this.isProcessingRequest = true;
private async processQueue() {
while (this.requestQueue.length > 0) {
const queueItem = this.requestQueue.shift();
let response = null;
@ -69,6 +64,7 @@ export default class QueueProcessor<T> {
}
}
}
this.requestInProcessing--;
this.isProcessingRequest = false;
}
}