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