Wie parallelisiert man eine Funktion, die eine Variable verwendet

Question

Ich habe eine Funktion, die zufällige URL generiert und versuchen, die Datei herunterzuladen.

void tryURL() 
{ 
    randURL.clear(); 
    for (unsigned short i = 0; i < urlLength; i++) { 
    randURL = randURL + (alphabet[(int)((double)rand()/(RAND_MAX + 1) * alphabetLength)]); 
    } 
    wcout << randURL << endl; 
    HRESULT getImg = URLDownloadToFile(NULL, LPCWSTR((beginURL + randURL + endURL).c_str()), LPCWSTR((randURL + L"/" + endURL).c_str()), 0, NULL); 
    if (SUCCEEDED(getImg)) 
    { 
    wcout << L"Success" << endl; 
    } 
} 

Wenn ich diese Funktion normalerweise ausführen, dann ist es gut funktionieren:

tryURL(); 
0ybOAt 
tryURL(); 
lTPKaR 
tryURL(); 
Ivi05m 
... 

Aber ich brauche in diesem Moment diese Funktion wiederholt Zeiten ausgeführt werden. Ich versuchte dies:

thread threads[10]; 

for (int i = 0; i < 10; ++i) { 
    threads[i] = thread(tryURL); 
} 

for (int i = 0; i < 10; ++i) { 
    threads[i].join(); 
} 

Und es gibt mir immer denselben Wert

0ybOAt0ybOAt 
0ybOAt 

0ybOAt0ybOAt 

0ybOAt 
0ybOAt0ybOAt 
0ybOAt 
0ybOAt 

Und selbst Endl tun ist manchmal nicht angezeigt.

Wie kann ich es beheben? Ich denke, es ist kaputt, weil immer die Variable randURL verwendet wird, aber ich weiß nicht, wie ich das umgehen kann.

Answer 1

Statt die gleiche Variable verwenden, stellen tryURLreturn die URL:

// assuming that URLs are strings 
std::string tryURL() { /* ... */ } 

Dann einen Vektor von std::future<std::string> erstellen, um die asynchronen Berechnungen darzustellen, die URLs kehrt:

std::vector<std::future<std::string>>> futures; 
futures.reserve(10); 

for (int i = 0; i < 10; ++i) 
{ 
    futures.emplace_back(std::async(std::launch::async, tryURL)); 
} 

Schließlich konsumieren Sie die URLs im Hauptthread:

bieten

Answer 2

Weitere Fragen auf Stackoverflow einige Hinweise:

• rand() with multiple threads
• iostream thread safety, must cout and cerr be locked separately?

Eine einfache Lösung für den rand() Problem ist es, die URL zu erzeugen: s im Hauptthread und Pass sie zum Faden.

void tryURL(std::wstring URL) 
... 
// TODO: Set randURL to a random URL 
threads[i] = thread(tryURL, randURL);