Ich arbeite an einem parallelen Matrix-Matrix-Multiplikator in MPI. Ich habe den Berechnungsteil, aber ich will auch CPU-Zeit berechnen. Ich bleibe stecken, weil es so aussieht, als ob einige Prozesse Start- und Endzeiten von 0 melden und für eine Aufgabe, die weniger als eine Sekunde dauern sollte (kleine Matrizen), meldet das Programm 1000+ zweite CPU-Zeiten (obwohl ich weiß, dass es läuft in weniger als einer Sekunde von der Beobachtung). Hier ist, was ich gerade mache:Berechnung der CPU-Zeit bei Verwendung von MPI
#include <time.h>
#include "mpi.h"
// other includes
int main()
{
int start, end, min_start, min_end;
if (rank == 0)
{
// setup stuff
start = clock();
MPI_Reduce(&min_start, &start, 1, MPI_INT, MPI_MIN, 0, MPI_COMM_WORLD);
// master computation stuff
end = clock();
MPI_Reduce(&max_end, &end, 1, MPI_INT, MPI_MAX, 0, MPI_COMM_WORLD);
cout << "CPU time was "
<< (double)(max_end - min_start)/CLOCKS_PER_SEC
<< " seconds" << endl;
}
else if (rank != 0)
{
// setup stuff
start = clock();
MPI_Reduce(&min_start, &start, 1, MPI_INT, MPI_MIN, 0, MPI_COMM_WORLD);
// slave computation stuff
end = clock();
MPI_Reduce(&max_end, &end, 1, MPI_INT, MPI_MAX, 0, MPI_COMM_WORLD);
}
}
Ich bin mir nicht sicher, was die Quelle des Fehlers ist. Wenn ich in dieser Debugging-Ausgabe hinzugefügt (nach der if (rank == 0)
und else if (rank != 0)
Anweisung)
MPI_Barrier(MPI_COMM_WORLD);
for (int i=0; i<size; i++)
{
if (rank == i)
cout << "(" << i << ") CPU time = "
<< end << " - " << start
<< " = " << end - start << endl;
MPI_Barrier(MPI_COMM_WORLD);
}
ich die folgenden Ausgabe
CPU time was 1627.91 seconds
(1) CPU time = 0 - 0 = 0
(2) CPU time = 0 - 0 = 0
(0) CPU time = 1627938704 - 32637 = 1627906067
(3) CPU time = 10000 - 0 = 10000
Zuerst würde ich 'clock()' überhaupt nicht verwenden. Sie können 'chrono' mit C++ 11 oder dessen Boost-Implementierung mit pre C++ 11 verwenden. –