Zmienna liczba asynchronicznych wątków z C++ 11

Question

Pracuję nad programem, w którym chciałbym użyć asynchronizacji w pętli. W przykładowym kodzie, który zawarłem, jest tylko 10 elementów, więc mogłem z łatwością stworzyć wyraźną zmienną dla każdego elementu. Jednak w moim głównym programie liczba elementów w wektorze może być różna. Idealnie chciałbym stworzyć wektor asynchronicznych wątków - po jednym dla każdego elementu w tablicy - które są wypychane z powrotem na wektor asynchroniczny, kiedy przechodzę przez pętlę. Następnie chcę poczekać na zakończenie wszystkich, a następnie użyć " get() ", aby zwrócić wszystkie swoje wyjścia.

Poniższy kod wywoła async, przypisując jawną zmienną dla każdego wątku, ale czy ktoś wie jak dynamicznie wywoływać asynchroniczne w wektorze bez konieczności jednoznacznego przypisania do niego zmiennej? Idealnie, chciałbym, aby ten program wywoływał "std :: cout" raz za każdym razem, gdy przechodził, zamiast tylko raz.

#include <iostream> 
#include <vector> 
#include <string> 
#include <future> 

std::string hi (std::string input) 
{ 
    return "hello, this is " + input; 
} 

int main() 
{ 
    std::vector<std::string> test_vector(10, "a test"); 
    std::future<std::string> a; 
    std::future<std::string> b; 

    for (int i = 0; i < test_vector.size (); i++) 
    { 
     a = std::async(std::launch::async, hi, test_vector[i]); 
    } 

    std::cout << a.get() << std::endl; 

    return 0; 
} 

Answer 1

Odpowiedź tym std::cout:

std::vector<std::future<std::string>> a; 
for (int i = 0; i < 10; ++i) { 
    a.emplace_back(std::async(hi)); 
} 
for (auto& element : a) { 
    std::cout << element.get() << std::endl; 
} 

Answer 2

Jeśli dobrze zrozumiałem, może być coś takiego:

std::vector<std::future<std::string>> vessel; 
for (int i = 0; i < test_vector.size (); i++) 
{ 
    std::future<std::string> aux; 
    aux = std::async(std::launch::async, hi); 
    vessel.push_back(aux); 
} 

Niestety nie mogę zamieścić jako komentarz, ale w ten sposób, w zależności od logiki, a jeśli to działa, to powinno być w stanie dynamicznie manipulować wektorem vessel.

---

Aktualizacja

jeszcze lepiej:

vessel.push_back(new std::future<std::string>); 
vessel[vessel.size()-1] = std::async(std::launch::async, hi); 

ten sposób nie trzeba jawnie zadeklarować zmienną. Ale trzeba będzie delete po zakończeniu:

for(int i=0; i<(int) vessel.size(); i++) 
{ 
    delete vessel[i]; 
} 

Answer 3

Problem ten można rozwiązać poprzez stworzenie wektor futures pasujące do Twojego wektor wątków, coś takiego:

#include <iostream> 
#include <vector> 
#include <string> 
#include <future> 

std::string hi(const std::string& input) 
{ 
    return "hello, this is " + input; 
} 

int main() 
{ 
    std::vector<std::string> tests = {"one", "two", "three", "four"}; 
    std::vector<std::future<std::string>> futures; 

    // add the futures to the futures vector as you launch 
    // your asynchronous functions 
    for(auto&& t: tests) 
     futures.emplace_back(std::async(std::launch::async, hi, std::cref(t))); 

    // collect your results 
    for(auto&& f: futures) 
     std::cout << f.get() << '\n'; 
} 

Uwaga wykorzystanie std::cref przejść przez const odniesienia. Użyj std::ref, aby przekazać non const reference.