1. <?php
  3. class LogQueue {
  5. private $queue = [];
  6. private $filePath = 'log_tasks.txt';
  8. public function enqueue(string $task): void {
  9. // Add task to the queue
  10. $this->queue[] = $task;
  11. $this->saveQueue();
  12. }
  14. public function dequeue(): string|null {
  15. // Remove and return the first task from the queue
  16. if (empty($this->queue)) {
  17. return null;
  18. }
  19. return array_shift($this->queue);
  20. }
  22. private function saveQueue(): void {
  23. // Save the queue to a file
  24. file_put_contents($this->filePath, implode("\n", $this->queue));
  25. }
  27. private function loadQueue(): void {
  28. // Load the queue from a file
  29. if (file_exists($this->filePath)) {
  30. $queueData = file($this->filePath, FILE_IGNORE_NEW_LINES | FILE_SKIP_EMPTY_LINES);
  31. $this->queue = $queueData ? array_reverse($queueData) : []; // Reverse to maintain order
  32. }
  33. }
  35. public function run(): void {
  36. // Process tasks from the queue
  37. $this->loadQueue();
  38. while (true) {
  39. $task = $this->dequeue();
  40. if ($task) {
  41. try {
  42. // Simulate log file processing
  43. echo "Processing task: $task\n";
  44. // Add your log file processing logic here
  45. usleep(500000); // Simulate work
  46. } catch (Exception $e) {
  47. echo "Error processing task '$task': " . $e->getMessage() . "\n";
  48. }
  49. } else {
  50. // Queue is empty, wait for a bit
  51. usleep(1000000);
  52. }
  53. }
  54. }
  55. }
  57. // Example Usage:
  58. $queue = new LogQueue();
  60. $queue->enqueue('process_file_1.log');
  61. $queue->enqueue('process_file_2.log');
  62. $queue->enqueue('process_file_3.log');
  64. // Start the queue processor in a separate thread/process
  65. $queue->run();
  67. ?>

Add your comment