ThreadPool 是一个简单的C++线程池，用于支持动态并行任务。
仓库链接： ThreadPool
知乎文章： C++实现线程池
-
#include "ThreadPool.h" class ParallelRadixSort : public ThreadPool { public: ... private: ... }
-
就像使用一般数据结构那样
{ pool = ThreadPool(4) pool.submit(...) }我们利用一下C++的RAII（Resource Acquisition Is initialization）技术，以避免手动等待线程池完成其任务。
Options是一个300行代码实现的C++命令行参数解析器，其中包含一个结构体Option（表示一个选项）和一个类Options（解析器类）。
Options以一组（或一个）字符串（帮助文档的模板）作为构造函数的输入，生成一个解析器，调用该解析器的parse成员函数，即可解析命令行参数，非常易用。
Options的使用示例参考test.cpp
struct Option {
bool is_given; // 判断该选项是否在命令行参数中出现
unsigned int num_args; // 选项需要几个参数
#ifdef TEST_OPTION_PARSER
std::string pattern; // 选项的模板，用于调试解析器
#endif
// 用于存储选项的参数的`vector`
std::vector<std::string> values;
};class Options {
public:
// 构造函数
Options(const std::string &lines);
Options(const std::initializer_list<std::string> &lines);
Options(const std::vector<std::string> &lines);
// 解析
void parse(int argc, const char * const argv[]);
// 打印帮助信息
void show_usage();
// 获取没有被选项捕获的参数
const std::vector<std::string> &args() const;
// 通过名字获取选项的结构体
const Option *operator[](const std::string &name);
// 获取选项的第一个值，返回字符串
const std::string &get(const std::string &name, const std::string &dval);
// 获取选项的第一个值，返回`int`
int get(const std::string &name, int dval);
// 获取选项的第`i`个值，返回字符串
const std::string &get(const std::string &name, size_t i, const std::string &dval);
// 获取选项的第`i`个值，返回`int`
int get(const std::string &name, size_t i, int dval);
// 判断选项`name`是否出现（用户是否输入）
bool has(const std::string &name);
}static Options options = {
"Usage: test [options...]",
"Test program for the header `ParallelRadixSort.h`",
"",
"Options:",
" -(c|-column) <column> columns per line when printing",
" -(n|-number) <number> the number of random numbers",
" -(r|-range) <lb> <ub> the range of random numbers",
" -(s|-show) print sorting result or not",
" -(t|-threads) <threads> number of threads to be used",
" -(?|-help) print this message and exit",
"",
"Examples:",
" ./test -t=4 --range 100 200",
" ./test -t 2 --range 1 10000 -n=100000000",
};直接把main函数的参数传入Options对象的parse成员函数进行调用即可
options.parse(argc, argv);options.get(<option_name>, <default_value>)其中 <option_name> 是帮助模板中选项的括号中给出的各项
比如，如果帮助模板中存在如下一行
" -(c|-column) <column> columns per line when printing"则可使用
options.get("-column", 4)或
options.get("c", 4)获取column选项的值。
absop@walle:ThreadPool$ make clean
rm -f test
absop@walle:ThreadPool$ make
g++ -o test test.cpp -std=c++17 -Wall -lpthread
absop@walle:ThreadPool$ time ./test
real 0m0.017s
user 0m0.000s
sys 0m0.007sabsop@walle:ThreadPool$ make clean
rm -f test
absop@walle:ThreadPool$ make d=t
g++ -o test test.cpp -std=c++17 -Wall -lpthread -DDEBUG
absop@walle:ThreadPool$调试命令行参数解析器
absop@walle:ThreadPool$ make clean
rm -f test
absop@walle:ThreadPool$ make top=t
g++ -o test test.cpp -std=c++17 -Wall -lpthread -DTEST_OPTION_PARSER
absop@walle:ThreadPool$absop@walle:ThreadPool$ make clean
rm -f test
absop@walle:ThreadPool$ make m=45
g++ -o test test.cpp -std=c++17 -Wall -lpthread -DRADIX_SORT_MIN_SIZE=45
absop@walle:ThreadPool$absop@walle:ThreadPool$ ./test -?
Usage: test [options...]
Test program for the header `ParallelRadixSort.h`
Options:
-c, --column <column> columns per line when printing
-n, --number <number> the number of random numbers
-r, --range <lb> <ub> the range of random numbers
-s, --show print sorting result or not
-t, --threads <threads> number of threads to be used
-?, --help print this message and exit
Examples:
./test -t=4 --range 100 200
./test -t 2 --range 1 10000 -n=100000000- 4线程
- 随机数范围 [1, 100000000]
- 100个随机数
- 不打印排序结果
- 打印时，每行7列
以每行5列输出排序结果
absop@walle:ThreadPool$ ./test -s -c=5
12820005 13451203 1622649 17027214 18235992
22391013 23846771 24315082 25262475 26838739
27216237 27540688 27887629 28112284 28334697
29370661 31324816 32624668 33565602 3535383
35895215 36738842 37359944 39208517 39217355
39282809 42139844 42478722 42540563 42692586
44627922 46902079 47494754 47849757 4810836
4853775 48853389 49751816 50514613 51202872
5121645 51593080 52487947 52796598 53116104
53884331 54167739 54172565 54481378 5467047
54945310 60229415 60447941 6193377 64377819
64591678 64694333 66625024 66870490 6835363
68632492 69421471 69465616 70230151 70402215
71704540 73900067 74181448 7432941 75272563
75287148 7541664 77039016 77269052 77351389
77873306 77943230 78382620 787226 78761985
801 84653530 84975452 86053826 86511027
86529980 88787930 90471148 90866396 91795343
92510844 9278448 92976645 93090434 93448001
9404434 95147484 95582749 96225670 96919440用于测试的机器的配置信息
- Intel(R) Core(TM) i5-6200U CPU @ 2.30GHz 2.40 GHz
- 8.00 GB (7.85 GB 可用)
- WSL 2
测试结果
-
4线程
absop@walle:ThreadPool$ time ./test -n 1000000 -t=4 real 0m1.422s user 0m4.749s sys 0m0.132s -
2线程
absop@walle:ThreadPool$ time ./test -n 1000000 -t=2 real 0m1.788s user 0m3.285s sys 0m0.030s -
单线程
absop@walle:ThreadPool$ time ./test -n 1000000 -t=1 real 0m2.633s user 0m2.582s sys 0m0.040s