1. class QueueGuard {
  2. constructor(queue) {
  3. this.queue = queue;
  4. }
  6. /**
  7. * Executes a function on the queue, handling potential errors.
  8. * @param {function} task - The function to execute.
  9. * @param {number} [maxRetries=3] - Maximum number of retries.
  10. * @param {number} [retryDelay=1000] - Delay between retries in milliseconds.
  11. * @returns {Promise<any>} - A promise that resolves with the result of the task or rejects if all retries fail.
  12. */
  13. async executeTask(task, maxRetries = 3, retryDelay = 1000) {
  14. let retries = 0;
  16. while (retries < maxRetries) {
  17. try {
  18. const result = await task();
  19. return result; // Success, return the result
  20. } catch (error) {
  21. retries++;
  22. console.warn(`Task failed (attempt ${retries}/${maxRetries}):`, error);
  24. if (retries < maxRetries) {
  25. await new Promise(resolve => setTimeout(resolve, retryDelay)); // Wait before retrying
  26. } else {
  27. throw error; // Re-throw the error if all retries failed
  28. }
  29. }
  30. }
  32. throw new Error("Max retries reached without success."); //Should not reach here, but good to have.
  33. }
  35. /**
  36. * Adds a task to the queue, guarded by the QueueGuard.
  37. * @param {function} task - The function to add to the queue.
  38. */
  39. addGuardedTask(task) {
  40. this.queue.push(async () => {
  41. try {
  42. return await this.executeTask(task);
  43. } catch (error) {
  44. console.error("Task failed within guarded execution:", error);
  45. throw error; // Re-throw to propagate the error if needed.
  46. }
  47. });
  48. }
  49. }
  51. //Example Usage:
  52. //const myQueue = [];
  53. //const queueGuard = new QueueGuard(myQueue);
  55. //async function myTask() {
  56. // // Simulate an exploratory task that might fail
  57. // return new Promise((resolve, reject) => {
  58. // setTimeout(() => {
  59. // if (Math.random() < 0.5) {
  60. // resolve("Task completed successfully!");
  61. // } else {
  62. // reject(new Error("Task failed intentionally!"));
  63. // }
  64. // }, 500);
  65. // });
  66. //}
  68. //queueGuard.addGuardedTask(myTask);
  70. //async function processQueue() {
  71. // while(myQueue.length > 0){
  72. // const task = myQueue.shift();
  73. // try {
  74. // const result = await task();
  75. // console.log("Queue Result:", result);
  76. // } catch(error){
  77. // console.error("Queue Error: ", error);
  78. // }
  79. // }
  80. //}
  82. //processQueue();

Add your comment