* @brief Helper to clear the queue between tests */
| 82 | * @brief Helper to clear the queue between tests |
| 83 | */ |
| 84 | void clearTaskRequestQueue() { |
| 85 | std::unique_lock<std::mutex> lock(queueMutex); |
| 86 | while (!taskRequestQueue.empty()) { |
| 87 | taskRequestQueue.pop(); |
| 88 | } |
| 89 | } |
| 90 | |
| 91 | /** |
| 92 | * @brief Helper to get current queue size |