Skip to content

Commit

Permalink
ready to merge
Browse files Browse the repository at this point in the history
  • Loading branch information
galabovaa committed Sep 24, 2024
1 parent 83822d8 commit 9215dd9
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions src/parallel/HighsTaskExecutor.h
Original file line number Diff line number Diff line change
Expand Up @@ -55,12 +55,12 @@ class HighsTaskExecutor {
#endif

std::atomic<int> referenceCount;
std::atomic<bool> hasStopped{false};

cache_aligned::shared_ptr<HighsSplitDeque::WorkerBunk> workerBunk;
std::vector<cache_aligned::unique_ptr<HighsSplitDeque>> workerDeques;
std::vector<std::thread> workerThreads;

std::atomic<bool> hasStopped{false};

HighsTask* random_steal_loop(HighsSplitDeque* localDeque) {
const int numWorkers = workerDeques.size();
Expand Down Expand Up @@ -95,7 +95,7 @@ class HighsTaskExecutor {
auto& executorHandle = threadLocalExecutorHandle();
executorHandle.ptr = ptr;

if (!hasStopped) {
if (!ptr->hasStopped) {
HighsSplitDeque* localDeque = ptr->workerDeques[workerId].get();
threadLocalWorkerDeque() = localDeque;

Expand Down

0 comments on commit 9215dd9

Please sign in to comment.