Class e std :: async sul membro della classe in C++

Question

Sto provando a scrivere un membro della classe che chiama un altro membro della classe più volte in parallelo.

Ho scritto un semplice esempio del problema e non riesco nemmeno a compilarlo. Cosa sto facendo di sbagliato nel chiamare std :: async? Credo che il problema sarebbe con come sto passando la funzione.

#include <vector> 
#include <future> 
using namespace std; 
class A 
{ 

int a,b; 
public: 
A(int i=1, int j=2){ a=i; b=j;} 

std::pair<int,int> do_rand_stf(int x,int y) 
{ 
    std::pair<int,int> ret(x+a,y+b); 
    return ret; 
} 

void run() 
{ 
    std::vector<std::future<std::pair<int,int>>> ran; 
    for(int i=0;i<2;i++) 
    { 
     for(int j=0;j<2;j++) 
     { 
      auto hand=async(launch::async,do_rand_stf,i,j); 
      ran.push_back(hand);  
     } 
    } 
    for(int i=0;i<ran.size();i++) 
    { 
     pair<int,int> ttt=ran[i].get(); 
     cout << ttt.first << ttt.second << endl; 
    } 
} 
}; 
int main() 
{ 
A a; 
a.run(); 
} 

compilazione: (. Il parametro implicito this)

g++ -std=c++11 -pthread main.cpp 

Answer 1

do_rand_stf è una funzione membro non statica e quindi non può essere chiamato senza un'istanza di classe Fortunatamente, std::async maniglie suoi parametri come std::bind, e bind a sua volta può utilizzare std::mem_fn per trasformare un puntatore a funzione membro in un functor che assume un parametro esplicito this, quindi tutto ciò che devi fare è passare this a std::async invocazione e utilizzare la sintassi valida puntatore a funzione membro quando passa il do_rand_stf:

auto hand=async(launch::async,&A::do_rand_stf,this,i,j); 

Ci sono altri problemi nel codice, però. Innanzitutto, si utilizza std::cout e std::endl senza #include ing <iostream>. Più seriamente, std::future non è copiabile, solo mobile, quindi non è possibile hand l'oggetto denominato hand senza utilizzare std::move. In alternativa, basta passare il risultato async-push_back direttamente:

ran.push_back(async(launch::async,&A::do_rand_stf,this,i,j)); 

Answer 2

È possibile passare il puntatore this ad un nuovo thread:

async([this]() 
{ 
    Function(this); 
});