1. class RequestThrottler {
  2. constructor(queue, delayMs) {
  3. this.queue = queue; // The task queue to throttle
  4. this.delayMs = delayMs; // Delay in milliseconds
  5. this.lastExecutionTime = 0;
  6. this.running = false;
  7. }
  9. async executeTask(task) {
  10. if (this.running) {
  11. // Queue the task if already running
  12. this.queue.push(task);
  13. return;
  14. }
  16. this.running = true;
  17. const now = Date.now();
  19. if (now - this.lastExecutionTime < this.delayMs) {
  20. // Wait if the delay hasn't passed
  21. const waitTime = this.delayMs - (now - this.lastExecutionTime);
  22. await new Promise(resolve => setTimeout(resolve, waitTime));
  23. }
  25. this.lastExecutionTime = Date.now();
  27. try {
  28. await task(); // Execute the task
  29. } catch (error) {
  30. console.error("Task failed:", error); // Log errors
  31. } finally {
  32. this.running = false;
  33. //Process the next task from the queue
  34. if(this.queue.length > 0){
  35. this.executeTask(this.queue.shift());
  36. }
  37. }
  38. }
  39. }
  42. //Example Usage
  43. // const taskQueue = [];
  44. // const throttler = new RequestThrottler(taskQueue, 1000); // Throttle to 1000ms (1 second)
  46. // // Simulate some tasks
  47. // async function task1() {
  48. // console.log("Task 1 executed");
  49. // await new Promise(resolve => setTimeout(resolve, 500));
  50. // }
  52. // async function task2() {
  53. // console.log("Task 2 executed");
  54. // await new Promise(resolve => setTimeout(resolve, 700));
  55. // }
  57. // throttler.executeTask(task1);
  58. // throttler.executeTask(task2);
  59. // throttler.executeTask(task1); //Will be throttled
  60. // throttler.executeTask(task2); //Will be throttled
  61. // throttler.executeTask(task1); //Will be throttled

Add your comment