1. /**
  2. * Monitors a task queue for errors and handles them gracefully.
  3. *
  4. * @param {Array<Function>} taskQueue An array of functions representing tasks to be executed.
  5. * @param {number} concurrency The maximum number of tasks to run concurrently. Defaults to 1.
  6. * @param {number} interval The monitoring interval in milliseconds. Defaults to 1000.
  7. */
  8. async function monitorTaskQueue(taskQueue, concurrency = 1, interval = 1000) {
  9. let runningTasks = 0;
  10. const taskPromises = []; // Store promises for each running task
  12. /**
  13. * Executes a single task and handles errors.
  14. * @param {Function} task
  15. */
  16. async function executeTask(task) {
  17. try {
  18. await task();
  19. console.log("Task completed successfully.");
  20. } catch (error) {
  21. console.error("Task failed:", error);
  22. //Graceful handling: Log the error, potentially retry, or skip.
  23. } finally {
  24. runningTasks--;
  25. taskPromises.splice(taskPromises.indexOf(taskPromise), 1); //remove the taskPromise
  26. }
  27. }
  29. /**
  30. * Starts executing tasks based on concurrency.
  31. */
  32. async function startTasks() {
  33. for (let i = 0; i < concurrency && taskQueue.length > 0; i++) {
  34. const task = taskQueue.shift();
  35. runningTasks++;
  37. const taskPromise = executeTask(task);
  38. taskPromises.push(taskPromise);
  40. // Continue with the next task.
  41. if (taskQueue.length === 0) {
  42. await Promise.all(taskPromises); //wait for all tasks to complete.
  43. return;
  44. }
  45. }
  46. }
  48. //Initial start.
  49. startTasks();
  51. //Regular monitoring loop
  52. setInterval(async () => {
  53. if (runningTasks > 0) {
  54. //Check for pending tasks
  55. try {
  56. await Promise.race(taskPromises.map(p => p.then(async (res) => {
  57. return new Promise((resolve, reject) => {
  58. try {
  59. await res;
  60. resolve();
  61. } catch (err) {
  62. reject(err);
  63. }
  64. });
  65. })));
  67. //If all tasks completed, reset running tasks.
  68. runningTasks = 0;
  69. } catch (error){
  70. console.error("Error during monitoring:", error);
  71. }
  72. }
  73. }, interval);
  74. }

Add your comment