1 #include "hmbdc/Copyright.hpp" 3 #include "hmbdc/pattern/PoolConsumer.hpp" 8 namespace hmbdc {
namespace pattern {
12 using ptr = std::shared_ptr<PoolMinus>;
13 void addConsumer(
PoolConsumer&, uint64_t poolThreadAffinityIn = 0xfffffffffffffffful);
14 uint32_t consumerSize()
const;
15 void start(uint16_t threadCount, uint64_t cpuAffinityMask = 0,
bool noUse =
true);
16 void startThruRecycling(uint16_t threadCount, uint64_t cpuAffinityMask = 0) {
17 start(threadCount, cpuAffinityMask);
19 void startAt(uint16_t threadCount, uint64_t cpuAffinityMask, std::vector<uint16_t>
const&) {
20 start(threadCount, cpuAffinityMask);
22 void runOnce(uint16_t threadSerialNumber);
26 ptr create(uint32_t maxConsumerSize) {
27 return std::shared_ptr<PoolMinus>(
Definition: PoolMinus.hpp:9
Definition: PoolConsumer.hpp:13