refactor: Move ThreadPool to util

diff --git a/src/CMakeLists.txt b/src/CMakeLists.txt
index 9e51429cd9ec1d88f4cf46625f56cd25db1baabb..8ec9abe259c1ccb47b8a0c62d85160a97a2ad064 100644 (file)
--- a/src/CMakeLists.txt
+++ b/src/CMakeLists.txt
@@ -8,7 +8,6 @@ set(
   Hash.cpp
   Logging.cpp
   ProgressBar.cpp
-  ThreadPool.cpp
   Util.cpp
   argprocessing.cpp
   assertions.cpp

diff --git a/src/core/mainoptions.cpp b/src/core/mainoptions.cpp
index f12c4f6ec58169d4faa14f3af7787ed1bb3bf9c5..1460246e0e063cc93461fa94f9e2ed8cd3a3cea4 100644 (file)
--- a/src/core/mainoptions.cpp
+++ b/src/core/mainoptions.cpp
@@ -24,7 +24,6 @@
 #include <InodeCache.hpp>
 #include <Logging.hpp>
 #include <ProgressBar.hpp>
-#include <ThreadPool.hpp>
 #include <Util.hpp>
 #include <assertions.hpp>
 #include <ccache.hpp>
@@ -43,6 +42,7 @@
 #include <util/Fd.hpp>
 #include <util/TemporaryFile.hpp>
 #include <util/TextTable.hpp>
+#include <util/ThreadPool.hpp>
 #include <util/UmaskScope.hpp>
 #include <util/XXH3_128.hpp>
 #include <util/environment.hpp>
@@ -329,7 +329,7 @@ trim_dir(const std::string& dir,
   if (recompress_level) {
     const size_t read_ahead = std::max(
       static_cast<size_t>(10), 2 * static_cast<size_t>(recompress_threads));
-    ThreadPool thread_pool(recompress_threads, read_ahead);
+    util::ThreadPool thread_pool(recompress_threads, read_ahead);
     core::FileRecompressor recompressor;
 
     std::atomic<uint64_t> incompressible_size = 0;

diff --git a/src/storage/local/LocalStorage.cpp b/src/storage/local/LocalStorage.cpp
index 8d54f81e1b95309fba473af02dfa2f6ec24de223..781fcb515d90ba4574e71ea12e31e298eb921d63 100644 (file)
--- a/src/storage/local/LocalStorage.cpp
+++ b/src/storage/local/LocalStorage.cpp
@@ -24,7 +24,6 @@
 #include <File.hpp>
 #include <Logging.hpp>
 #include <MiniTrace.hpp>
-#include <ThreadPool.hpp>
 #include <Util.hpp>
 #include <assertions.hpp>
 #include <core/CacheEntry.hpp>
@@ -37,6 +36,7 @@
 #include <util/Duration.hpp>
 #include <util/TemporaryFile.hpp>
 #include <util/TextTable.hpp>
+#include <util/ThreadPool.hpp>
 #include <util/expected.hpp>
 #include <util/file.hpp>
 #include <util/filesystem.hpp>
@@ -842,7 +842,7 @@ LocalStorage::recompress(const std::optional<int8_t> level,
 {
   const size_t read_ahead =
     std::max(static_cast<size_t>(10), 2 * static_cast<size_t>(threads));
-  ThreadPool thread_pool(threads, read_ahead);
+  util::ThreadPool thread_pool(threads, read_ahead);
   core::FileRecompressor recompressor;
 
   std::atomic<uint64_t> incompressible_size = 0;

diff --git a/src/util/CMakeLists.txt b/src/util/CMakeLists.txt
index adfc7709fa752e5dee4eb962e4d9a7ef4dd098e1..deb2cad65e75b34c117b4cb6b53972edafd24511 100644 (file)
--- a/src/util/CMakeLists.txt
+++ b/src/util/CMakeLists.txt
@@ -6,6 +6,7 @@ set(
   LongLivedLockFileManager.cpp
   TemporaryFile.cpp
   TextTable.cpp
+  ThreadPool.cpp
   TimePoint.cpp
   Tokenizer.cpp
   UmaskScope.cpp

diff --git a/src/ThreadPool.cpp b/src/util/ThreadPool.cpp
similarity index 95%
rename from src/ThreadPool.cpp
rename to src/util/ThreadPool.cpp
index d5da4d5071c459f77bbc631dfa10f90669a31cfc..1c62e5d7265d060042d57557853c0c305d4a8f3b 100644 (file)
--- a/src/ThreadPool.cpp
+++ b/src/util/ThreadPool.cpp
@@ -1,4 +1,4 @@
-// Copyright (C) 2019-2020 Joel Rosdahl and other contributors
+// Copyright (C) 2019-2023 Joel Rosdahl and other contributors
 //
 // See doc/AUTHORS.adoc for a complete list of contributors.
 //
@@ -18,6 +18,8 @@
 
 #include "ThreadPool.hpp"
 
+namespace util {
+
 ThreadPool::ThreadPool(size_t number_of_threads, size_t task_queue_max_size)
   : m_task_queue_max_size(task_queue_max_size)
 {
@@ -86,3 +88,5 @@ ThreadPool::worker_thread_main()
     task();
   }
 }
+
+} // namespace util

diff --git a/src/ThreadPool.hpp b/src/util/ThreadPool.hpp
similarity index 93%
rename from src/ThreadPool.hpp
rename to src/util/ThreadPool.hpp
index fa46538259cb4eb7066b80568afe3b020cde8b0f..32b85e8772ecf809c9fbf87644421f125af590ea 100644 (file)
--- a/src/ThreadPool.hpp
+++ b/src/util/ThreadPool.hpp
@@ -1,4 +1,4 @@
-// Copyright (C) 2019-2021 Joel Rosdahl and other contributors
+// Copyright (C) 2019-2023 Joel Rosdahl and other contributors
 //
 // See doc/AUTHORS.adoc for a complete list of contributors.
 //
@@ -25,6 +25,8 @@
 #include <queue>
 #include <thread>
 
+namespace util {
+
 class ThreadPool
 {
 public:
@@ -47,3 +49,5 @@ private:
 
   void worker_thread_main();
 };
+
+} // namespace util