Fix crash in clusted fork-join algorithm

Hopsan · May 15, 2024 · eb90f09 · eb90f09
1 parent 7666888
commit eb90f09
Showing 1 changed file with 6 additions and 6 deletions.
diff --git a/HopsanCore/src/ComponentSystem.cpp b/HopsanCore/src/ComponentSystem.cpp
@@ -2770,28 +2770,28 @@ void ComponentSystem::simulateMultiThreaded(const double startT, const double st
             }
 
             //C components
-            tt = new std::thread[mComponentCptrs.size()];
-            for (size_t c=0; c < mComponentCptrs.size(); ++c)
+            tt = new std::thread[mpMultiThreadPrivates->mSplitCVector.size()];
+            for (size_t c=0; c < mpMultiThreadPrivates->mSplitCVector.size(); ++c)
             {
                 tt[c] = std::thread(simOneStep,
                                     &mpMultiThreadPrivates->mSplitCVector[c],
                                     mTime);
             }
-            for(size_t c=0; c<mComponentCptrs.size(); ++c)
+            for(size_t c=0; c<mpMultiThreadPrivates->mSplitCVector.size(); ++c)
             {
                 tt[c].join();
             }
             delete[] tt;
 
             //Q components
-            tt = new std::thread[mComponentQptrs.size()];
-            for (size_t q=0; q < mComponentQptrs.size(); ++q)
+            tt = new std::thread[mpMultiThreadPrivates->mSplitQVector.size()];
+            for (size_t q=0; q < mpMultiThreadPrivates->mSplitQVector.size(); ++q)
             {
                 tt[q] = std::thread(simOneStep,
                                     &mpMultiThreadPrivates->mSplitQVector[q],
                                     mTime);
             }
-            for(size_t q=0; q<mComponentQptrs.size(); ++q)
+            for(size_t q=0; q<mpMultiThreadPrivates->mSplitQVector.size(); ++q)
             {
                 tt[q].join();
             }