PoolPipe.h

Go to the documentation of this file.

 
#pragma once
 
#include <vector>
#include <memory>
#include <mutex>
#include <condition_variable>
#include <functional>
#include <sys/wait.h>
#include <sys/stat.h>
 
namespace HepLib {
 
    class Pool {
    public:
        explicit Pool(const std::vector<void*> & vec);
        void* acquire();
        void release(void* obj);
    private:
        std::vector<void*> ava;
        std::mutex mtx;
        std::condition_variable cv;
    };
    
    class Pipe {
    public:
        explicit Pipe(const std::function<std::string(const std::string &)> & fi);
        ~Pipe();
        std::string run(const std::string &code);
    private:
        int p2c[2], c2p[2];
        pid_t pid;
        std::function<std::string(const std::string &)> f;
    };
    
    class PipePool {
    public:
        explicit PipePool(int size, const std::function<std::string(const std::string &)> & f);
        std::string run(const std::string & code);
        std::vector<std::string> run_all(const std::string &code);
        ~PipePool();
    private:
        Pool* pool;
        std::vector<Pipe*> pipe_ptr_vec;
    };
    
    
}