1. <?php
  3. class TaskQueue
  4. {
  5. private $queue = [];
  6. private $maxSize;
  8. public function __construct(int $maxSize = 100)
  9. {
  10. $this->maxSize = $maxSize;
  11. }
  13. public function enqueue(array $record): void
  14. {
  15. // Add task to the queue
  16. $this->queue[] = $record;
  18. // Limit queue size
  19. if (count($this->queue) > $this->maxSize) {
  20. $this->dequeue(); // Remove oldest task if queue is full
  21. }
  22. }
  24. public function dequeue(): array|null
  25. {
  26. // Remove and return the oldest task (FIFO)
  27. if (empty($this->queue)) {
  28. return null; // Queue is empty
  29. }
  31. return array_shift($this->queue);
  32. }
  34. public function isEmpty(): bool
  35. {
  36. return empty($this->queue);
  37. }
  39. public function size(): int
  40. {
  41. return count($this->queue);
  42. }
  43. }
  45. // Example Usage:
  46. $queue = new TaskQueue(20); // Limit queue to 20 items
  48. //Simulate adding records
  49. for ($i = 0; $i < 30; $i++) {
  50. $record = ['id' => $i, 'data' => 'some data'];
  51. $queue->enqueue($record);
  52. }
  54. // Process tasks from the queue
  55. while (!$queue->isEmpty()) {
  56. $task = $queue->dequeue();
  57. if ($task) {
  58. // Process the task (e.g., save to database, process data)
  59. echo "Processing task: " . $task['id'] . "\n";
  60. // Simulate processing time
  61. usleep(500000); // 0.5 seconds
  62. }
  63. }
  65. ?>

Add your comment