MCPcopy Create free account
hub / github.com/Snapchat/Valdi / setMaxConcurrentTasks

Method setMaxConcurrentTasks

valdi_core/src/valdi_core/cpp/Threading/TaskQueue.cpp:274–283  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

272}
273
274void 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
285void TaskQueue::setListener(const Shared<IQueueListener>& listener) {
286 std::lock_guard<Mutex> lockGuard(_mutex);

Callers

nothing calls this directly

Calls 1

notifyAllMethod · 0.80

Tested by

no test coverage detected