| 272 | } |
| 273 | |
| 274 | void TaskQueue::setMaxConcurrentTasks(size_t maxConcurrentTasks) { |
| 275 | { |
| 276 | std::lock_guard<Mutex> lockGuard(_mutex); |
| 277 | if (_maxConcurrentTasks == maxConcurrentTasks) { |
| 278 | return; |
| 279 | } |
| 280 | _maxConcurrentTasks = maxConcurrentTasks; |
| 281 | } |
| 282 | _condition.notifyAll(); |
| 283 | } |
| 284 | |
| 285 | void TaskQueue::setListener(const Shared<IQueueListener>& listener) { |
| 286 | std::lock_guard<Mutex> lockGuard(_mutex); |