spieleprogrammierer.de - Forum und Wiki zur Spieleprogrammierung und Spieleentwicklung

C-/C++-Quelltext

#include <iostream>
#include <thread>
#include <string>
#include <vector>
#include <Windows.h>
#include "BoeseX.h"

//Globale Ergebnisse
uint ergBoese = 0;
uint ergSauber = 0;
double dauer = 0;
uint laufendeThreads = 0;

//Thread-Methode
void starteBerechnung(uint start, uint ende, Ziffer boese) {
    ++laufendeThreads;

    BoeseX* berechnung = new BoeseX(start,ende, boese);
    berechnung->Berechne();

    ergBoese    += berechnung->getTrefferBoese();
    ergSauber   += berechnung->getTrefferSauber();
    dauer       += berechnung->getDauer();
    std::cout << dauer << std::endl;

    --laufendeThreads;
}

void ergebnisAusgeben() {
    while (laufendeThreads != 0) { Sleep(10); };

    //Ergebnis anzeigen
    std::cout << "Boese Zahlen: \t\t" << ergBoese << std::endl;
    std::cout << "Saubere Zahlen: \t" << ergSauber << std::endl;
    std::cout << "#################################" << std::endl;
    std::cout << "Benchmark: " << dauer << " Sekunden" << std::endl;
}

int main() {
    uint obergrenze;
    std::cout << "Obergrenze eingeben: " << std::endl;
    std::cin >> obergrenze;

    uint threads;
    std::cout << "Wieviele Threads verwenden: " << std::endl;
    std::cin >> threads;

    std::cout << "#################################" << std::endl;

    //Array der Threads
    std::vector<std::thread> t;

    uint start = 0;
    uint ende = obergrenze / threads;

    //Threads starten
    for (int i=0;i < threads; ++i) {
        t.push_back( 
            std::thread(starteBerechnung, start, ende * (i+1), SIEBEN) 
        );

        start += ende;
    }

    //Ausgabe-Thread starten
    std::thread ausgabe = std::thread(ergebnisAusgeben);
    ausgabe.join();

    return 0;
}