1. <?php
  3. /**
  4. * Flushes output from task queues with a timeout.
  5. *
  6. * @param array $queue An array representing the task queue. Each element
  7. * should be an array with 'data' and 'timeout' keys.
  8. * 'data' is the data to be flushed.
  9. * 'timeout' is the timeout in seconds.
  10. * @return bool True on success, false on failure.
  11. */
  12. function flushTaskQueue(array $queue): bool
  13. {
  14. $startTime = time();
  15. $success = true;
  17. foreach ($queue as $task) {
  18. $data = $task['data'];
  19. $timeout = $task['timeout'];
  21. if (empty($data)) {
  22. continue; // Skip tasks with empty data.
  23. }
  25. $output = fopen('php://output', 'w'); // Open output stream for writing.
  27. if ($output === false) {
  28. error_log("Error opening output stream for flushing task: " . json_encode($task));
  29. $success = false;
  30. continue;
  31. }
  33. $start = time();
  35. // Flush output with timeout.
  36. try {
  37. flush($output);
  38. // Wait for the timeout.
  39. while (time() - $start < $timeout) {
  40. usleep(1000); // Sleep for 1 millisecond.
  41. }
  43. if (time() - $start >= $timeout) {
  44. error_log("Task flushed beyond timeout: " . json_encode($task));
  45. $success = false;
  46. }
  47. } catch (Exception $e) {
  48. error_log("Error flushing task: " . json_encode($task) . ". Exception: " . $e->getMessage());
  49. $success = false;
  50. }
  52. fclose($output);
  53. }
  55. return $success;
  56. }

Add your comment