多个Jthread线程，每个线程完成mpmcpipeline中一个stage的处理，实现软件流水。第一个stage收到sentinal value时，所有work线程都退出。 #include <gtest/gtest.h> #include <folly/MPMCPipeline.h> #include <vector> #include <thread> #include <boost/mp1…
多个Jthread线程，每个线程完成mpmcpipeline中一个stage的处理，实现软件流水。第一个stage收到sentinal value时，所有work线程都退出。 #include <gtest/gtest.h> #include <folly/MPMCPipeline.h> #include <vector> #include <thread> #include <boost/mp1…
讨论
登录后参与讨论
还没有评论，来说第一句吧。