C++ - Passaggio di dati tra thread

Ho un pool di thread costituito da 4 thread: t1, t2, t3 e t4. Sono in esecuzione contemporaneamente, ma l'input da t3 e t4 dipende dall'output di t2. Come devo implementare la coda dei messaggi in modo che dopo il completamento di t2, invii i dati di output a t3 e t4 per l'elaborazione? Ho cercato di implementare la coda dei messaggi utilizzando il meccanismo di blocco, ma sembra che il blocco sia piuttosto costoso. C'è un meccanismo lock-free che passa i dati tra i thread? Sto utilizzando boost :: thread in visual studio 2010.C++ - Passaggio di dati tra thread

fonte

2014-11-19 Bent

Imparare dal seguente link: http://stackoverflow.com/questions/20595760/c-communication-between-threads –

Boost ha una coda senza blocco: http://www.boost.org/doc/libs/1_56_0/doc/html/lockfree.html.

fonte

2014-11-19 09:38:22 Tomo

Hi Tomo, per il mio caso sia T3 e T4 hanno bisogno di ottenere i dati di uscita da T2. Quindi, mi chiedo chi ritirerà i dati dalla coda dei messaggi? Dovrebbe essere t2 perchè non siamo sicuri se t3 o t4 saranno completi per primi? Intendo ogni volta che t2 accoda nuovi dati, eseguirà anche la cancellazione. – Bent

Sì, t2 dovrebbe mettere il suo output nella coda. T3 e T4 dovrebbero controllare periodicamente se c'è qualcosa nella coda da elaborare. Supponendo che t3 e t4 abbiano altre cose da fare. In caso contrario (il loro unico compito è attendere l'output di t2 e processarlo), dimenticarsi delle code prive di lock e andare con una soluzione di blocco. Se i fili devono comunque aspettare, il costo del blocco non dovrebbe essere motivo di preoccupazione. – Tomo

È possibile considerare tbb. Fornisce una vasta gamma di concetti paralleli tra cui concurrent_queue, concurrent_bounded_queue (per l'attesa), pipeline, flow::graph. I primi due sono disponibili anche in ppl all'interno di MS VS 2010.

fonte

2014-11-19 09:55:18 Anton

Ciao Anton, grazie per aver risposto! Perché attualmente il mio progetto utilizza boost lib, quindi mi concentrerò maggiormente sull'aumento. Ma darò un'occhiata anche a TBB se non trovo alcuna soluzione. :)) – Bent

C++ - Passaggio di dati tra thread

risposta

Problemi correlati