MINIFI-338: Convert processor threads to use thread pools Author: Marc Parisi <phroc...@apache.org>
Signed-off-by: Bin Qiu <b...@apache.com> This closes #177 Project: http://git-wip-us.apache.org/repos/asf/nifi-minifi-cpp/repo Commit: http://git-wip-us.apache.org/repos/asf/nifi-minifi-cpp/commit/58c21e0b Tree: http://git-wip-us.apache.org/repos/asf/nifi-minifi-cpp/tree/58c21e0b Diff: http://git-wip-us.apache.org/repos/asf/nifi-minifi-cpp/diff/58c21e0b Branch: refs/heads/master Commit: 58c21e0bf95197bf746b7f2c45ba5b3f66010d29 Parents: 5fca46f 9d50035 Author: Bin Qiu <benqiu2...@gmail.com> Authored: Wed Aug 2 16:18:16 2017 -0700 Committer: Bin Qiu <benqiu2...@gmail.com> Committed: Wed Aug 2 16:32:44 2017 -0700 ---------------------------------------------------------------------- libminifi/include/EventDrivenSchedulingAgent.h | 2 +- libminifi/include/SchedulingAgent.h | 2 +- libminifi/include/ThreadedSchedulingAgent.h | 56 +++++- libminifi/include/TimerDrivenSchedulingAgent.h | 2 +- libminifi/include/core/Processor.h | 5 +- libminifi/include/utils/ThreadPool.h | 195 +++++++++++++++++++- libminifi/src/EventDrivenSchedulingAgent.cpp | 13 +- libminifi/src/FlowController.cpp | 14 +- libminifi/src/SchedulingAgent.cpp | 4 +- libminifi/src/ThreadedSchedulingAgent.cpp | 44 ++--- libminifi/src/TimerDrivenSchedulingAgent.cpp | 10 +- libminifi/test/unit/SocketTests.cpp | 2 +- libminifi/test/unit/ThreadPoolTests.cpp | 2 +- 13 files changed, 291 insertions(+), 60 deletions(-) ----------------------------------------------------------------------
