Open Build Service

domecam.changes Changed

_service Changed

domecam-0.1.19.obscpio/.hgtags -> domecam-0.1.20.obscpio/.hgtags Changed

domecam-0.1.19.obscpio/CMakeLists.txt -> domecam-0.1.20.obscpio/CMakeLists.txt Changed

domecam-0.1.19.obscpio/exe/domecam-replayd/main.cpp -> domecam-0.1.20.obscpio/exe/domecam-replayd/main.cpp Changed

domecam-0.1.19.obscpio/exe/domecamd/main.cpp -> domecam-0.1.20.obscpio/exe/domecamd/main.cpp Changed

domecam-0.1.20.obscpio/include/thread_group.h Added

@@ -0,0 +1,46 @@
+/*
+ * SPDX-License-Identifier: GPL-3.0-or-later
+ *
+ * Copyright (C) 2017-2023  Matwey V. Kornilov <matwey.kornilov@gmail.com>
+ */
+
+#ifndef _THREAD_GROUP_H
+#define _THREAD_GROUP_H
+
+#include <cassert>
+#include <thread>
+#include <utility>
+#include <vector>
+
+
+class thread_group {
+public:
+	using value_type = std::thread;
+
+	template<class Function, class... Args>
+	explicit thread_group(std::size_t size, Function&& f, Args&&... args) {
+		assert(size > 0);
+
+		threads_.reserve(size);
+
+		for (std::size_t worker_id = 0; worker_id < size; ++worker_id)
+			threads_.emplace_back(std::forward<Function>(f), worker_id, std::forward<Args>(args)...);
+	}
+
+	bool joinable() const noexcept;
+	void join();
+
+	std::size_t size() const noexcept { return threads_.size(); }
+
+	void swap(thread_group& other) noexcept;
+
+private:
+	std::vector<value_type> threads_;
+};
+
+
+namespace std {
+	void swap(thread_group& lhs, thread_group& rhs) noexcept;
+} // std
+
+#endif // _THREAD_GROUP_H

domecam-0.1.20.obscpio/src/thread_group.cpp Added

domecam.obsinfo Changed

Changes of Revision 34