Eu tenho uma aplicação na qual há vários modos de paralelização. Entretanto, quando vou paralelizar através de fork() a barreira não é compartilhada entre os processos, há alguma diferença do Shm em lidar com a instanciação via new ou há outra forma de prover o compartilhamento dessa barreira?
OBS: não sei se faz diferença, mas a barrier é um objeto static na classe pai.
#include "ProcessMode.hpp"
ProcessMode::ProcessMode(IndexGenerator *index_generator_template, numerical *numerical_array, short number_of_processors)
: ParalelizationMode(index_generator_template, numerical_array, number_of_processors) {
// Sharing the barrier for use among the processes
int ptr_id = shmget(IPC_PRIVATE, sizeof(Barrier), IPC_CREAT | 0666);
ParalelizationMode::barrier = (Barrier*) shmat(ptr_id, NULL, 0);
ParalelizationMode::barrier = new Barrier(number_of_processors);
}
void ProcessMode::run() {
pid_t pid;
int id = 0;
// Create processes
for (short i = 1; i < number_of_processors; i++) {
pid = fork();
if(pid > 0) {
continue;
}
else {
id = i;
break;
}
}
calculate(new Calculator(numerical_array, index_generator_template->clone(id)));
ParalelizationMode::barrier->wait();
if (pid == 0) exit(0);
}