close thread pool + parallel CasImpl::Initialize (#576)

* close thread pool at destruction
* parallell casimpl::initialize

1 files changed, 17 insertions, 4 deletions

diff --git a/src/zenstore/cas.cpp b/src/zenstore/cas.cpp
index fc549a729..c6bfda8b9 100644
--- a/src/zenstore/cas.cpp
+++ b/src/zenstore/cas.cpp
@@ -12,6 +12,7 @@
 #include <zencore/fmtutils.h>
 #include <zencore/logging.h>
 #include <zencore/memory.h>
+#include <zencore/scopeguard.h>
 #include <zencore/string.h>
 #include <zencore/testing.h>
 #include <zencore/testutils.h>
@@ -104,10 +105,22 @@ CasImpl::Initialize(const CidStoreConfiguration& InConfig)
 	const bool IsNewStore = OpenOrCreateManifest();
 
 	// Initialize payload storage
-
-	m_LargeStrategy.Initialize(m_Config.RootDirectory, IsNewStore);
-	m_TinyStrategy.Initialize(m_Config.RootDirectory, "tobs", 1u << 28, 16, IsNewStore);	 // 256 Mb per block
-	m_SmallStrategy.Initialize(m_Config.RootDirectory, "sobs", 1u << 30, 4096, IsNewStore);	 // 1 Gb per block
+	{
+		WorkerThreadPool			   WorkerPool(3, "CasImpl::Initialize");
+		std::vector<std::future<void>> Work;
+		Work.emplace_back(
+			WorkerPool.EnqueueTask(std::packaged_task<void()>{[&]() { m_LargeStrategy.Initialize(m_Config.RootDirectory, IsNewStore); }}));
+		Work.emplace_back(WorkerPool.EnqueueTask(std::packaged_task<void()>{[&]() {
+			m_TinyStrategy.Initialize(m_Config.RootDirectory, "tobs", 1u << 28, 16, IsNewStore);  // 256 Mb per block
+		}}));
+		Work.emplace_back(WorkerPool.EnqueueTask(std::packaged_task<void()>{[&]() {
+			m_SmallStrategy.Initialize(m_Config.RootDirectory, "sobs", 1u << 30, 4096, IsNewStore);	 // 1 Gb per block
+		}}));
+		for (std::future<void>& Result : Work)
+		{
+			Result.get();
+		}
+	}
 }
 
 bool