TheCloud/dwarfs
1
0
Fork 0
mirror of https://github.com/mhx/dwarfs.git synced 2025-09-10 21:10:02 -04:00
Code Issues Packages Projects Releases Wiki Activity

Support packaged tasks in worker groups

Browse Source
This commit is contained in:
Marcus Holland-Moritz 2021-03-20 07:06:40 +01:00
parent 13eeaba658
commit db5576ac29
1 changed files with 6 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
include/dwarfs/worker_group.h
View File

@ -22,6 +22,7 @@
#pragma once #pragma once
#include <cstddef> #include <cstddef>
#include <future>
#include <limits> #include <limits>
#include <memory> #include <memory>
#include <utility> #include <utility>
@ -72,6 +73,11 @@ class worker_group {
size_t size() const { return impl_->size(); } size_t size() const { return impl_->size(); }
size_t queue_size() const { return impl_->queue_size(); } size_t queue_size() const { return impl_->queue_size(); }
template <typename T>
bool add_job(std::packaged_task<T()>&& task) {
return add_job([task = std::move(task)]() mutable { task(); });
}
class impl { class impl {
public: public:
virtual ~impl() = default; virtual ~impl() = default;