6502/CLK
1
0
Fork 0
mirror of https://github.com/TomHarte/CLK.git synced 2025-02-16 18:30:32 +00:00
Code Issues Projects Releases Wiki Activity

Simplifies perform_parallel slightly.

Browse Source
This commit is contained in:
Thomas Harte 2018-02-10 23:39:30 -05:00
parent e1cab52c84
commit 8eea55b51c
1 changed files with 9 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
Analyser/Dynamic/MultiMachine/Implementation/MultiCRTMachine.cpp
View File

@ -24,25 +24,25 @@ void MultiCRTMachine::perform_parallel(const std::function<void(::CRTMachine::Ma
std::mutex mutex; std::mutex mutex;
{ {
std::lock_guard<std::mutex> machines_lock(machines_mutex_); std::lock_guard<std::mutex> machines_lock(machines_mutex_);
std::lock_guard<std::mutex> lock(mutex);
outstanding_machines = machines_.size(); outstanding_machines = machines_.size();
for(std::size_t index = 0; index < machines_.size(); ++index) { for(std::size_t index = 0; index < machines_.size(); ++index) {
queues_[index].enqueue([&mutex, &condition, this, index, function, &outstanding_machines]() { CRTMachine::Machine *crt_machine = machines_[index]->crt_machine();
CRTMachine::Machine *crt_machine = machines_[index]->crt_machine(); queues_[index].enqueue([&mutex, &condition, crt_machine, function, &outstanding_machines]() {
if(crt_machine) function(crt_machine); if(crt_machine) function(crt_machine);
std::unique_lock<std::mutex> lock(mutex); {
outstanding_machines--; std::lock_guard<std::mutex> lock(mutex);
outstanding_machines--;
}
condition.notify_all(); condition.notify_all();
}); });
} }
} }
while(true) { std::unique_lock<std::mutex> lock(mutex);
std::unique_lock<std::mutex> lock(mutex); condition.wait(lock, [&outstanding_machines] { return !outstanding_machines; });
condition.wait(lock);
if(!outstanding_machines) break;
}
} }
void MultiCRTMachine::perform_serial(const std::function<void (::CRTMachine::Machine *)> &function) { void MultiCRTMachine::perform_serial(const std::function<void (::CRTMachine::Machine *)> &function) {