Wie kann ich eine Funktion mehrmals gleichzeitig ausführen lassen?

Question

Ich habe den folgenden Code als meine Hauptfunktion:

int main(int argc,char** argv) 
{ 
    CommandLineParser cmd(argc,argv,keys); 
    if (cmd.has("help")) { 
     cmd.about(""); 
     cmd.printMessage(); 
     return 0; 
    } 
    String alphaFile = cmd.get<String>("alpha"); 
    String betaFile = cmd.get<String>("beta"); 
    String gammaFile = cmd.get<String>("gamma"); 
    String deltaFile = cmd.get<String>("delta"); 
    int featureToUse = cmd.get<int>("feature"); 
    int classifier = cmd.get<int>("classifier"); 

    runOnSingleCamera(alphaFile, featureToUse, classifier); 
    runOnSingleCamera(betaFile, featureToUse, classifier); 
    runOnSingleCamera(gammaFile, featureToUse, classifier); 
    runOnSingleCamera(deltaFile, featureToUse, classifier); 

    return 0; 
} 

runOnSingleCamera ist eine meiner anderen Funktionen, und jeder Anruf läuft die gleiche Sache auf verschiedene Video-Dateien. Der Code muss für alle Videodateien gleichzeitig ausgeführt werden und auf dasselbe globale Array zugreifen.

Was wäre der beste Weg, dies zu tun?

Wenn die Lösung Multithreading ist, geben Sie bitte an, was in meiner cmake-Datei enthalten sein sollte, da ich damit experimentiert habe, es aber nicht zum Laufen bringen konnte.

Answer 1

Wie wäre es damit:

int main(int argc,char** argv) 
{ 
    CommandLineParser cmd(argc,argv,keys); 
    if (cmd.has("help")) { 
     cmd.about(""); 
     cmd.printMessage(); 
     return 0; 
    } 
    String alphaFile = cmd.get<String>("alpha"); 
    String betaFile = cmd.get<String>("beta"); 
    String gammaFile = cmd.get<String>("gamma"); 
    String deltaFile = cmd.get<String>("delta"); 
    int featureToUse = cmd.get<int>("feature"); 
    int classifier = cmd.get<int>("classifier"); 

    std::thread t1(runOnSingleCamera, alphaFile, featureToUse, classifier); 
    std::thread t2(runOnSingleCamera, betaFile, featureToUse, classifier); 
    std::thread t3(runOnSingleCamera, gammaFile, featureToUse, classifier); 
    std::thread t4(runOnSingleCamera, deltaFile, featureToUse, classifier); 

    t1.join(); 
    t2.join(); 
    t3.join(); 
    t4.join(); 

    return 0; 
} 

Multithreading ist kein Spielzeug though. Wenn hier alles unabhängig ist, dann ist das in Ordnung. Wenn Variablen in irgendeiner Weise voneinander abhängen, müssen Sie vorsichtig sein.

Wenn Ihr Array schreibgeschützt ist, ist dies in Ordnung. Wenn Ihr Array von allen Threads geändert werden muss, ist dies ein Zerstörungsrezept. Seien Sie wieder vorsichtig mit Shared Variablen unter Threads. Es ist ein sehr großes Thema. Lesen Sie über race-conditions.

Beachten Sie, dass damit alles nach Wert übergeben wird; d. h., alles wird in Ihre Funktion kopiert (auch wenn Ihre Funktion durch Verweis darauf Bezug nimmt). Sie sollten std::ref() als Referenz verwenden. Lesen Sie mehr über std::thread here.