1. <?php
  3. class TaskQueue {
  5. private $queue = [];
  6. private $max_tasks = 10; // Limit number of tasks in the queue
  8. public function enqueue(string $dataset_name, callable $task_function) {
  9. // Add task to the queue
  10. $this->queue[] = [
  11. 'dataset' => $dataset_name,
  12. 'task' => $task_function,
  13. ];
  15. // Limit queue size
  16. if (count($this->queue) > $this->max_tasks) {
  17. $this->dequeue(); // Remove the oldest task if queue is full
  18. }
  19. }
  21. private function dequeue() {
  22. if (!empty($this->queue)) {
  23. array_shift($this->queue); // Remove the first element (oldest task)
  24. }
  25. }
  27. public function process() {
  28. while (!empty($this->queue)) {
  29. $task = array_shift($this->queue); // Get the next task
  31. $dataset_name = $task['dataset'];
  32. $task_function = $task['task'];
  34. try {
  35. // Basic sanity checks
  36. if (empty($dataset_name)) {
  37. throw new Exception("Dataset name cannot be empty.");
  38. }
  40. if (!is_callable($task_function)) {
  41. throw new Exception("Task function is not callable.");
  42. }
  45. // Execute the task
  46. $task_function($dataset_name); // Execute the task with the dataset name
  47. echo "Processed dataset: $dataset_name\n"; // Log the processing
  48. } catch (Exception $e) {
  49. echo "Error processing dataset $dataset_name: " . $e->getMessage() . "\n"; // Log errors
  50. }
  51. }
  52. }
  54. public function getQueueSize(): int {
  55. return count($this->queue);
  56. }
  57. }
  59. // Example usage:
  61. // Define some dummy task functions
  62. function processDataset1(string $dataset_name) {
  63. echo "Simulating processing of dataset: $dataset_name\n";
  64. // Add your actual dataset processing logic here
  65. }
  67. function processDataset2(string $dataset_name) {
  68. echo "Simulating processing of dataset: $dataset_name\n";
  69. }
  72. // Create a TaskQueue instance
  73. $queue = new TaskQueue();
  75. // Enqueue some tasks
  76. $queue->enqueue("data_set_a", 'processDataset1');
  77. $queue->enqueue("data_set_b", 'processDataset2');
  78. $queue->enqueue("data_set_c", function (string $dataset_name) {
  79. echo "Custom processing of dataset: $dataset_name\n";
  80. });
  81. $queue->enqueue("data_set_d", 'processDataset1');
  82. $queue->enqueue("data_set_e", 'processDataset2');
  83. $queue->enqueue("data_set_f", function (string $dataset_name) {
  84. echo "Custom processing of dataset: $dataset_name\n";
  85. });
  86. $queue->enqueue("data_set_g", 'processDataset1');
  87. $queue->enqueue("data_set_h", 'processDataset2');
  88. $queue->enqueue("data_set_i", function (string $dataset_name) {
  89. echo "Custom processing of dataset: $dataset_name\n";
  90. });
  91. $queue->enqueue("data_set_j", 'processDataset1'); //Will trigger dequeue, as queue is now at max size.
  95. // Process the queue
  96. $queue->process();
  98. ?>

Add your comment