- // send
- comm.data_flush(false);
- mutex.acquire();
- real_load += received_load;
- received_load = 0.0;
- std::for_each(neigh.begin(), neigh.end(),
- std::bind(&process::data_send, this, _1));
- mutex.release();
+ do {
+ // receive (do not block if there is something to compute)
+ data_receive(real_load > 0.0 ? 0.0 : opt::min_comp_iter_duration);
+
+ // send
+ comm.data_flush(false);
+ mutex.acquire();
+ real_load += received_load;
+ received_load = 0.0;
+ std::for_each(neigh.begin(), neigh.end(),
+ std::bind(&process::data_send, this, _1));
+ mutex.release();
+
+ ++all_comp_iter;