#include "msg_thread.h"
#include "neighbor.h"
#include "options.h"
+#include "synchro.h"
class process {
public:
double real_load; // current load
double expected_load; // expected load in bookkeeping mode
+ mutex_t mutex; // synchronization between threads
+ condition_t cond;
+
// Load-balancing loop
+ msg_thread* lb_thread;
void load_balance_loop();
// Simulate computation loop
- msg_thread* compute_thread;
void compute_loop();
bool still_running();