C++ Alloc Fehler Hinzufügen von Objekten zu Vector (oder Deque oder List) in einem OpenMPI For-Schleife

Question

Ich benutze C++ (geschrieben für Windows und Linux) für OpenMPI kompiliert. Ich bekomme eine seltsame Reihe von Zuordnungsfehlern, wenn ich ein Klassenobjekt zu einem Vektor innerhalb der OpenMPI for-Schleife hinzufüge. Das Debuggen zeigt ein sich änderndes Muster von Zuweisungsfehlern, alle zentriert um meine "AddEntry()" - Methode, aber die Fehler fallen niemals an einer konsistenten Stelle in der Schleife oder auf einem konsistenten Element innerhalb des Objekts, das ich hinzufüge (daher glaube ich das Objekt ist nicht das Problem, diese Details sind nicht im Fragecode enthalten). Ich habe versucht, Platz für den Vektor zu reservieren, und ich habe versucht, Lösungen sowohl mit Deque und Liste. Ich habe versucht, das Objekt an das Add-Mitglied als ein Objekt, Verweis und Zeiger übergeben (instanziiert mit 'neu()') und keine dieser Lösungen das Problem gelöst. Dies ist mein Code:

#include "MyEntryClass.h" 
#include "MyVectorClass.h" 

#include <omp.h> 

CMyVectorClass::CMyVectorClass() 
{ 
    try 
    { 
     m_vEntries.clear(); 
     m_vEntries.reserve(750000); 
    } 
    catch (exception ex) 
    { 
     cout << "ERROR [CMyVectorClass] Exception Code: " << ex.what() << "\n"; 
    } 
} 

// Interface (public) 

bool CMyVectorClass::AddEntry(CMyVectorClass_Entry& eAdd) 
{ 
    try 
    { 
     m_vEntries.push_back(eAdd); 

     return true; 
    } 
    catch (exception ex) 
    { 
     cout << "ERROR [AddEntry] Exception Code: " << ex.what() << "\n"; 
    } 

    return false; 
} 

bool CMyVectorClass::DoOMPLoop() 
{ 
    // Max processors for omp 
    int nMaxProcs 
    // Continue, if true 
    volatile bool vbContinue = true; 
    // Loop counter 
    long lMaxCount = 100000; 

    try 
    { 
     // Iterate through files 
     // Declare team size 
     #pragma omp parallel for shared(vbContinue) num_threads(nMaxProcs) 
     for (long lCount = 0; lCount < lMaxCount; lCount++) 
     { 
      // The entry object to add 
      CMyEntryClass cAdd; 

      // Do some stuff to the entry 
      cAdd.SetStuff(); 

      // Catalog the data 
      vbContinue = AddEntry(cAdd); 
     } 
    } 
    catch (exception ex) 
    { 
     cout << "ERROR [DoOMPLoop] Exception Code: " << ex.what() << "\n"; 
    } 

    return false; 
} 

// Implementation (private) 

Dieses Problem hat mich viele Stunden der Frustration kosten versuchen zu lösen und keine der Hilfe, die ich auf Stackoverflow finden (oder dem ‚Netz im Allgemeinen) hat mir ermöglicht, das Problem zu beheben (obwohl es mir geholfen hat, anderen Code zu optimieren). Bitte helfen.

Answer 1

Nach vielen Versuchen und Drangsalierung erkannte ich, dass die Zuteilungsfehler nicht die Ursache des Problems waren (da meine Maschine über einen Speicher verfügt und das Reservelimit nie annähernd überschritten wurde). Ich fing an, die AddEntry() - Methode innerhalb des OpenMPI zu vermuten, die Schleife verursachte Kollisionen. Also habe ich "resize" anstelle von "reserve" verwendet und ich habe eine indexierte "SetEntryAtIndex()" -Funktion verwendet, um ein Objekt an einer bestimmten Stelle im Vektor einfach zurückzusetzen (beachten Sie, dass diese Art von Direktzugriff nicht bei allen ähnlichen Containern erlaubt ist) . Dies ist mein Code jetzt:

#include "MyEntryClass.h" 
#include "MyVectorClass.h" 

#include <omp.h> 

CMyVectorClass::CMyVectorClass() 
{ 
    try 
    { 
     m_vEntries.clear(); 
     m_vEntries.resize(750000); 
    } 
    catch (exception ex) 
    { 
     cout << "ERROR [CMyVectorClass] Exception Code: " << ex.what() << "\n"; 
    } 
} 

// Interface (public) 

bool CMyVectorClass::SetEntryAtIndex(CMyVectorClass_Entry& eSet, long lIndex) 
{ 
    try 
    { 
     if ((lIndex >= 0) && (lIndex < m_vEntries.size())) 
     { 
      m_vEntries[lIndex] = eSet; 

      return true; 
     } 
     else 
     { 
      ReportTimeStamp("[SetEntryAtIndex]", "ERROR: Index [" + ConvertLongToString(lIndex) + "] is Out of Range [0:" + ConvertLongToString(m_vEntries.size()) + "]"); 
     } 
    } 
    catch (exception ex) 
    { 
     cout << "ERROR [SetEntryAtIndex] Exception Code: " << ex.what() << "\n"; 
    } 

    return false; 
} 

bool CMyVectorClass::DoOMPLoop() 
{ 
    // Max processors for omp 
    int nMaxProcs 
    // Continue, if true 
    volatile bool vbContinue = true; 
    // Loop counter 
    long lMaxCount = 100000; 

    try 
    { 
     // Iterate through files 
     // Declare team size 
     #pragma omp parallel for shared(vbContinue) num_threads(nMaxProcs) 
     for (long lCount = 0; lCount < lMaxCount; lCount++) 
     { 
      // The entry object to add 
      CMyEntryClass cAdd; 

      // Do some stuff to the entry 
      cAdd.SetStuff(); 

      // Catalog the data 
      vbContinue = SetEntryAtIndex(cAdd, lCount); 
     } 
    } 
    catch (exception ex) 
    { 
     cout << "ERROR [DoOMPLoop] Exception Code: " << ex.what() << "\n"; 
    } 

    return false; 
} 

// Implementation (private) 

Der Trick, um ein vollständig zu erstellen ist Ändern der Größe (und sogar OVER) besiedeltes Vektor und dann einen Index, um sicherzustellen, sind keine Kollisionen innerhalb der OpenMPI Schleife.

Answer 2

Ich denke, es muss etwas anderes falsch mit dem ersten Ausschnitt sein. Vielleicht verdirbst du den Vektor im Code, der nicht gezeigt wird? Der kleine Ausschnitt unten funktioniert mehr oder weniger gleich und funktioniert gut. Beachten Sie, dass die Schleife über das Ende hinausgeht und der Vektor sich selbst ändert.

#include <vector> 

int main(int arg,char*arv[]) 
{ 

    std::vector <int> my_vec; 

    my_vec.clear(); 
    my_vec.resize(750000); 

    for(int i=0;i<760000;i++) 
    my_vec.push_back(i); 
    return 0; 
} 

--Matt