Bibliothèque C ++ pour renforcer le pipeline d'exécution

Je donnerais des blocs de construction en filetage http://threadingbuildingblocks.org/ a essayez. C'est une source ouverte et une plateforme croisée. L'article Wikipedia est plutôt bon: http://fr.wikipedia.org/wiki/intel_threading_building_blocks < / p>

Je viens de lire aujourd'hui sur raftlib , qui utilise des modèles et des classes pour créer des éléments de pipeline appelés "noyaux". Il permet un pipeline série tel que l'exemple Bash que vous avez montré, en plus des données de données parallèles. De Exemple World Hello sur la page d'accueil:

#include <raft>
#include <raftio>
#include <cstdlib>
#include <string>

class hi : public raft::kernel
{
public:
    hi() : raft::kernel()
    {
       output.addPort< std::string >( "0" ); 
    }

    virtual raft::kstatus run()
    {
        output[ "0" ].push( std::string( "Hello World\n" ) );
        return( raft::stop ); 
    }
};


int
main( int argc, char **argv )
{
    /** instantiate print kernel **/
    raft::print< std::string > p;
    /** instantiate hello world kernel **/
    hi hello;
    /** make a map object **/
    raft::map m;
    /** add kernels to map, both hello and p are executed concurrently **/
    m += hello >> p;
    /** execute the map **/
    m.exe();
    return( EXIT_SUCCESS );
}