salsa 0.7.1
Loading...
Searching...
No Matches
TaskExecutorForkZmq.hh
1#pragma once
2
3#include "ActorZmq.hh"
4#include "TaskExecutor.hh"
5
6namespace Salsa {
15
17public:
18 TaskExecutorForkZmq(zactor_t * pActor = nullptr);
19 virtual ~TaskExecutorForkZmq();
20
21 virtual bool run(std::string worker, std::string upstream);
22 virtual void * pipe() const;
23 virtual bool handlePipe(std::vector<std::string> & extra);
24
25protected:
26 zactor_t * mpZActor = nullptr;
27};
28} // namespace Salsa
TaskExecutorForkZmq class.
virtual bool handlePipe(std::vector< std::string > &extra)
Handle pipe.
virtual void * pipe() const
virtual bool run(std::string worker, std::string upstream)
Run task.
TaskExecutorForkZmq(zactor_t *pActor=nullptr)
zactor_t * mpZActor
ZMQ Actor pointer.
Base TaskExecutor class.