Grupo de subprocesos de C++

Question

¿Qué es una buena implementación de código abierto de un grupo de subprocesos para que C++ use en el código de producción (algo así como aumentar)?

Proporcione su propio código de ejemplo o un enlace al uso de código de ejemplo.

Answer 1

Creo que todavía no se acepta en Boost, pero es un buen punto de partida: threadpool. Algunos ejemplos de uso, desde el sitio 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. 
} 

El argumento "2" al grupo indica el número de subprocesos. En este caso, la destrucción de tp espera a que finalicen todos los hilos.

Answer 2

Es posible que desee ver en http://threadpool.sourceforge.net/

No es difícil de implementar por sí mismo utilizando thread poolBoost.Thread. Dependiendo de la tarea, es posible que desee utilizar el contenedor lock-free para la cola en lugar de uno de Standard Template Library. Por ejemplo, contenedor fifo de la biblioteca lock free.

¡Buena suerte!

Answer 3

This library se basa en Boost.Thread. Hay un short tutorial con algún código de ejemplo. Si esto no hace lo que desea, puede usarlo como línea de base.

Asegúrese de tener una versión de Boost> = 1.37 si sigue esta ruta.

Answer 4

Creo que puede emular un grupo de subprocesos con un io_service en boost :: asio. Puede controlar el número de subprocesos disponibles para el grupo io_service y luego puede "publicar" tareas en el io_service, que será ejecutado por uno de los subprocesos del grupo. Cada tarea debe ser un funtor (creo).

No puedo poner un ejemplo aquí en este momento, pero la documentación de asio sobre los grupos io_service describirá cómo se puede hacer esto.

Answer 5

Se describe una implementación de ejemplo utilizando el marco ffead-cpphere. Proporciona implementación directa, basada en prioridad y una agrupación de subprocesos programada. Verifíquelo ...

Answer 6

He escrito un pequeño ejemplo here. Básicamente lo que hay que hacer es poner en práctica este pedazo de código:

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

Aquí está una cola de tareas sólo de encabezado simple utilizando un grupo de subprocesos (construida sobre Boost): taskqueue.hpp

El TaskQueue project page incluye una muestra aplicación que demuestra how to use it: