Pool di thread C++

Question

Che cosa è una buona implementazione open source di un pool di thread per C++ da utilizzare nel codice di produzione (qualcosa come boost)?

Fornire il proprio codice di esempio o un collegamento per l'utilizzo del codice di esempio.

Answer 1

Penso che non sia ancora accettato in Boost, ma un buon punto di partenza: threadpool. Alcuni esempi di utilizzo, dal sito Web:

#include "threadpool.hpp" 

using namespace boost::threadpool; 

// Some example tasks 
void first_task() 
{ 
    ... 
} 

void second_task() 
{ 
    ... 
} 

void third_task() 
{ 
    ... 
} 

void execute_with_threadpool() 
{ 
    // Create a thread pool. 
    pool tp(2); 

    // Add some tasks to the pool. 
    tp.schedule(&first_task); 
    tp.schedule(&second_task); 
    tp.schedule(&third_task); 

    // Leave this function and wait until all tasks are finished. 
} 

L'argomento "2" per il pool indica il numero di thread. In questo caso, la distruzione di tp attende la fine di tutti i thread.

Answer 2

Si potrebbe desiderare di guardare http://threadpool.sourceforge.net/

Non è difficile da attuare thread pool da soli, usando Boost.Thread. A seconda dell'attività, è possibile utilizzare il contenitore lock-free per la coda anziché uno da Standard Template Library. Ad esempio, il contenitore fifo dalla libreria lock free.

Buona fortuna!

Answer 3

This library build su Boost.Thread. C'è un short tutorial con qualche codice di esempio. Se questo non fa ciò che vuoi, puoi usarlo come base.

Assicurati di essere su una versione Boost> = 1,37 se segui questo percorso.

Answer 4

Credo che si possa emulare un pool di thread con un io_service in boost :: asio. È possibile controllare il numero di thread disponibili per il pool io_service e quindi è possibile "postare" le attività su io_service, che verrà eseguito da uno dei thread nel pool. Ognuno di questi compiti deve essere un funtore (credo).

Non riesco a mettere un esempio qui adesso, ma la documentazione di asio sui pool io_service illustrerà come ciò può essere fatto.

Answer 5

Un'implementazione di esempio che utilizza il framework ffead-cpp è descritta here. Fornisce l'implementazione del pool di thread diretta, basata su priorità e programmata. Dai un'occhiata ...

Answer 6

Ho scritto un piccolo esempio here. Fondamentalmente quello che dovete fare è quello di attuare questo pezzo di codice:

asio::io_service io_service; 
boost::thread_group threads; 
auto_ptr<asio::io_service::work> work(new asio::io_service::work(io_service)); 

// Spawn enough worker threads 
int cores_number = boost::thread::hardware_concurrency(); 
for (std::size_t i = 0; i < cores_number; ++i){ 
    threads.create_thread(boost::bind(&asio::io_service::run, &io_service)); 
} 
// Post the tasks to the io_service 
for(vector<string>::iterator it=tasks.begin();it!=tasks.end();it++){ 
    io_service.dispatch(/* YOUR operator()() here */); 
} 
work.reset(); 

Answer 7

Ecco una semplice coda di un'attività di testa-solo con un pool di thread (costruito su Boost): taskqueue.hpp

Il TaskQueue project page include un campione applicazione dimostrativa how to use it: