| | |
| | | } |
| | | }; |
| | | |
| | | int nwriters[] = {1, 10, 100}; |
| | | int nwriters[] = {1, 10, 100, 1000}; |
| | | int nreaders[] = {2}; |
| | | const int64_t total_msg = 1000 * 100; |
| | | const int64_t total_msg = 1000 * 1000; |
| | | |
| | | auto Test = [&](auto &www, auto &rrr, bool isfork) { |
| | | for (auto nreader : nreaders) { |
| | |
| | | // typedef ThreadManager Manager; |
| | | // const bool isfork = IsSameType<Manager, ProcessManager>::value; |
| | | |
| | | { |
| | | if (0) { |
| | | ThreadManager tw, tr; |
| | | printf("---------------- Testing thread io: -------------------------------------------------------\n"); |
| | | Test(tw, tr, false); |
| | | } |
| | | { |
| | | |
| | | if (1) { |
| | | ProcessManager pw, pr; |
| | | printf("================ Testing process io: =======================================================\n"); |
| | | Test(pw, pr, true); |