C++ 11 ile değişken sayıda asenkron iş parçacığı sayısı

Question

Döngüde uyumsuzluğu kullanmak istediğim bir program üzerinde çalışıyorum. İçerdiğim örnek kodda sadece 10 öğe var, bu yüzden her öğe için kolayca bir değişken oluşturabilirim. Ancak, ana programımda, vektördeki elemanların sayısı değişebilir. İdeal olarak, asenkron iş parçacıklarının bir vektörünü oluşturmak istiyorum - dizideki her eleman için bir tane - ki ben döngüsel vektörde geri dönerken tekrar dönüyorum. Sonra hepsini tamamlamak için beklemek istiyorum ve sonra kullanıyorum " tüm çıkışlarını geri almak için()

aşağıda kodu, her iş parçacığı için açık bir değişken atayarak asenk arayacak ama kimse dinamik açıkça bunun için bir değişken atamak zorunda kalmadan bir vektör içinde uyumsuz çağrı nasıl biliyor? İdeal olarak, bu programın her seferinde bir kez değil, bir kez yerine "std :: cout" adını vermesini istiyorum.

#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

std::cout dahil bir cevap:

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

Eğer doğru anladıysam, olabilir gibi bir şey:

Ben mantığı bağlı bir yorumun, ancak bu şekilde, olarak açamazsınız, ve eğer çalışırsa, o zaman olmalı

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); 
} 

Maalesef vessel vektörünü dinamik olarak manipüle edebilir.

---

daha iyisi Güncelleme

: Açıkça bir değişken bildirmek gerekmez

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

bu şekilde. Ama bir kez yapılır delete gerekir:

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

Answer 3

Sen ipler vektör maç için vadeli bir vektör oluşturarak bu çözebilir, böyle bir şey: std::cref kullanımı Kat geçmek zorundadır

#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'; 
} 

Not referans. olmayan const başvuruları geçmek için std::ref kullanın.