1 #include "hmbdc/Copyright.hpp" 3 #include "hmbdc/pattern/PoolConsumer.hpp" 7 namespace hmbdc {
namespace pattern {
9 template <
typename Buffer>
11 void addConsumer(
PoolConsumer&, uint64_t poolThreadAffinityIn = 0xfffffffffffffffful);
12 uint32_t consumerSize()
const;
13 void start(uint16_t threadCount, uint64_t cpuAffinityMask = 0
14 ,
bool thatIsAll =
true);
15 void startAll(uint64_t cpuAffinityMask = 0);
16 void startThruRecycling(uint16_t threadCount, uint64_t cpuAffinityMask = 0);
17 void runOnce(uint16_t threadSerialNumber);
21 std::shared_ptr<PoolT> create(Buffer& lfb, uint32_t maxConsumerSize) {
22 return std::shared_ptr<PoolT>(
23 new PoolT(lfb, maxConsumerSize)
28 PoolT(Buffer&, uint32_t);
Definition: PoolConsumer.hpp:13
Definition: Client.hpp:11