C++

thread pool

Recherche :

Mot : Pseudo : Filtrer
Bas de page
Auteur	Sujet : thread pool

xterminhate

Si vis pacem, para bellum.

Bonjour,

Je cherche des informations sur les architectures de type thread pool en C++. Pouvez vous m'indiquer un site qui explique ou détaille une telle implémentation. Est-il préférable d'exploiter un framework orienté réseau (.Net, ACE et Cie) ?

Merci.

Publicité

Lam's

Profil: bas.

http://forum.hardware.fr/hardwaref [...] 6556-1.htm
[:dawa]

Un ThreadPool, c'est bêtement une collection (une liste, un tableau, etc.) de Threads qui sont prêtes à exécuter les tâches que tu leur fournis.

Ca marche très bien si tu fais faire le dispatch de ton boulot par une "Command Queue".

xterminhate

Si vis pacem, para bellum.

Je souhaiterais me baser sur boost::thread. Je peux certainement m'insiprer de PACC pour faire une sur couche au dessus de boost pour gérer le pool.

kamal102

ou est le probleme...

as-tu réussi à utiliser la librairie PACC pour les threads ?
C'est-à-dire à la compiler pour qu'elle soit utilisée comme une librairie dans vs c++ .net?

xterminhate

Si vis pacem, para bellum.

Je tenais à coder ça par moi même, et bien le resultat est pas triste bien sur. Assert dans Boost::mutex.inl. toute suggestion est la bienvenue.

Code :

template< typename task, typename function >
struct thread_pool : private boost::noncopyable
{
// one thread of the pool
struct one_thread
{
// constructor
one_thread( bool & r, fifo< task >& f ) : running( r ), task_queue( f ) {};
// thread function
void operator()() const
{
while( running )
function()( task_queue.read() );
}
private:
bool& running;
fifo< task >& task_queue;
};
// constructor
thread_pool( unsigned const & thread_number ) :
task_queue( thread_number * 2 ),
running( true )
{
// create all the threads of the pool
for( unsigned index = 0; index != thread_number; ++index )
tg.create_thread( one_thread( running, task_queue ) );
}
// new task
inline void push_task( task const & t )
{
task_queue.write( t );
}
// stop
inline void stop()
{
running = false;
}
// destructor
~thread_pool()
{
running = false;
tg.join_all();
}
private:
// thread group
thread_group tg;
// message queue
fifo< task > task_queue;
// status
bool running;
};

Au cas ou, voici le code de la fifo (qui marche parfaitement).

Code :

template< typename X >
struct fifo : private boost::noncopyable
{
fifo( const int& n ) :
begin( 0 ),
end( 0 ),
buffered( 0 ),
circular_buf( n )
{
}
void write( const X& m )
{
lock lk( monitor );
while ( buffered == circular_buf.size() )
buffer_not_full.wait( lk );
circular_buf[ end ] = m;
end = ( end + 1 ) % circular_buf.size();
++buffered;
buffer_not_empty.notify_one();
}
X read()
{
lock lk( monitor );
while ( buffered == 0 )
buffer_not_empty.wait( lk );
X i = circular_buf[ begin ];
begin = ( begin + 1 ) % circular_buf.size();
--buffered;
buffer_not_full.notify_one();
return i;
}
private:
unsigned int begin, end, buffered;
vector< X > circular_buf;
condition buffer_not_full, buffer_not_empty;
mutex monitor;
};

---------------
Cordialement, Xterm-in'Hate...

xterminhate

Si vis pacem, para bellum.

boost::thread_group est buggé dans mon environnement de développement. C'est bien la première fois qu'un composant boost foire...

---------------
Cordialement, Xterm-in'Hate...

FORUM HardWare.fr

Programmation

C++

thread pool

Sujets relatifs
Créer un Thread, c'est bien et le fermer...?	augmenter la large pool sous oracle 9i
thread	[Java/C#] Arret d'un Thread par le GC
récupérer un thread	[MFC]Thread
[Delphi] Pourquoi ce thread ne fonctionne pas ?	Passage paramètre à une thread
[linux 2.4 usb] isochrone implique-t-il thread ?	Return avec un thread
Plus de sujets relatifs à : thread pool

Page générée en 0.054 secondes