tursom/memgraph
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Destruct atomic only after all the threads are destructed

Browse Source
This commit is contained in:
János Benjamin Antal 2023-04-17 11:04:23 +02:00
parent fbceea3537
commit 9ad44928ac
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/storage/v2/durability/snapshot.cpp
View File

@ -521,9 +521,9 @@ template <typename TFunc>
void RecoverOnMultipleThreads(const size_t thread_count, const TFunc &func, const std::vector<BatchInfo> &batches) {
utils::Synchronized<std::optional<RecoveryFailure>, utils::SpinLock> maybe_error{};
{
std::atomic<uint64_t> batch_counter = 0;
std::vector<std::jthread> threads;
threads.reserve(thread_count);
std::atomic<uint64_t> batch_counter = 0;
for (auto i{0U}; i < thread_count; ++i) {
threads.emplace_back([&func, &batches, &maybe_error, &batch_counter]() {