1. /**
  2. * Task Queue Integrity & Rate Limiting Diagnostics
  3. *
  4. * Provides functions to verify task queue integrity and enforce rate limits.
  5. */
  7. class TaskQueue {
  8. constructor(maxRequestsPerSecond = 10) {
  9. this.queue = [];
  10. this.rateLimit = maxRequestsPerSecond;
  11. this.lastRequestTime = 0;
  12. }
  14. /**
  15. * Adds a task to the queue. Rate limits are enforced.
  16. * @param {Function} task The task to execute.
  17. * @returns {Promise<any>} A promise that resolves with the task result.
  18. */
  19. addTask(task) {
  20. return new Promise((resolve, reject) => {
  21. const now = Date.now();
  23. // Rate limiting check
  24. if (now - this.lastRequestTime < 1000 / this.rateLimit) {
  25. // Rate limit exceeded. Reject the promise.
  26. reject(new Error("Rate limit exceeded."));
  27. return;
  28. }
  30. this.lastRequestTime = now;
  32. // Add task to queue (simulated)
  33. this.queue.push(task);
  35. // Execute task.
  36. task()
  37. .then(result => {
  38. resolve(result);
  39. })
  40. .catch(error => {
  41. reject(error);
  42. });
  43. });
  44. }
  46. /**
  47. * Clears the queue. Useful for testing/diagnostics.
  48. */
  49. clearQueue() {
  50. this.queue = [];
  51. this.lastRequestTime = 0;
  52. }
  54. /**
  55. * Gets the current size of the queue.
  56. * @returns {number}
  57. */
  58. getQueueSize() {
  59. return this.queue.length;
  60. }
  61. }
  63. /**
  64. * Example Usage & Diagnostics
  65. */
  67. // Simulate tasks
  68. function task1() {
  69. return new Promise(resolve => setTimeout(() => {
  70. console.log("Task 1 completed");
  71. resolve("Result 1");
  72. }, 500));
  73. }
  75. function task2() {
  76. return new Promise(resolve => setTimeout(() => {
  77. console.log("Task 2 completed");
  78. resolve("Result 2");
  79. }, 200));
  80. }
  82. function task3() {
  83. return new Promise(resolve => setTimeout(() => {
  84. console.log("Task 3 completed");
  85. resolve("Result 3");
  86. }, 800));
  87. }
  90. // Create a task queue with a rate limit of 5 requests per second
  91. const queue = new TaskQueue(5);
  93. // Simulate submitting tasks
  94. async function simulateTasks() {
  95. for (let i = 0; i < 20; i++) {
  96. try {
  97. await queue.addTask(() => task1()); // Simulate submitting tasks
  98. } catch (error) {
  99. console.error("Task failed:", error.message);
  100. }
  101. }
  102. }
  104. simulateTasks();
  106. // Diagnostic: Check queue size after submitting tasks
  107. console.log("Queue size after tasks submitted:", queue.getQueueSize());
  109. //Diagnostic: Clear the queue
  110. queue.clearQueue();
  111. console.log("Queue size after clearing:", queue.getQueueSize());

Add your comment