c++11多线程-从零基础到手撕线程池

资源文件列表(大概)

文件名

大小

C++11_Thread/.vs/

C++11_Thread/.vs/C++11_Thread/

C++11_Thread/.vs/C++11_Thread/FileContentIndex/

C++11_Thread/.vs/C++11_Thread/FileContentIndex/2efc1733-320e-43da-952a-20acd86973fd.vsidx

10.32KB

C++11_Thread/.vs/C++11_Thread/FileContentIndex/8286db81-5a0b-4f56-86b6-4800d6881a12.vsidx

9.8KB

C++11_Thread/.vs/C++11_Thread/FileContentIndex/e177a58a-4e13-41e6-b34a-2ee067eba6ce.vsidx

10.56KB

C++11_Thread/.vs/C++11_Thread/FileContentIndex/e259bf2c-2819-452c-ad1a-37426286f9d5.vsidx

10.33KB

C++11_Thread/.vs/C++11_Thread/FileContentIndex/f1a6150e-6ddf-4bca-8529-a71916072fbc.vsidx

16KB

C++11_Thread/.vs/C++11_Thread/v17/

C++11_Thread/.vs/C++11_Thread/v17/.suo

53KB

C++11_Thread/.vs/C++11_Thread/v17/Browse.VC.db

41.63MB

C++11_Thread/.vs/C++11_Thread/v17/ipch/

C++11_Thread/.vs/C++11_Thread/v17/ipch/AutoPCH/

C++11_Thread/.vs/C++11_Thread/v17/ipch/AutoPCH/3e9227c547a57351/

C++11_Thread/.vs/C++11_Thread/v17/ipch/AutoPCH/3e9227c547a57351/THREADPOOL.ipch

896KB

C++11_Thread/.vs/C++11_Thread/v17/ipch/AutoPCH/497566869a95c925/

C++11_Thread/.vs/C++11_Thread/v17/ipch/AutoPCH/497566869a95c925/Դ.ipch

37.13MB

C++11_Thread/.vs/C++11_Thread/v17/ipch/AutoPCH/51f50dafecae4225/

C++11_Thread/.vs/C++11_Thread/v17/ipch/AutoPCH/51f50dafecae4225/Դ.ipch

41.88MB

C++11_Thread/.vs/C++11_Thread/v17/ipch/AutoPCH/5337d72c0b3fe6db/

C++11_Thread/.vs/C++11_Thread/v17/ipch/AutoPCH/5337d72c0b3fe6db/Դ.ipch

52.88MB

C++11_Thread/.vs/C++11_Thread/v17/ipch/AutoPCH/770bf456789b538/

C++11_Thread/.vs/C++11_Thread/v17/ipch/AutoPCH/770bf456789b538/Դ.ipch

41.88MB

C++11_Thread/.vs/C++11_Thread/v17/ipch/AutoPCH/b2e85697c768f023/

C++11_Thread/.vs/C++11_Thread/v17/ipch/AutoPCH/b2e85697c768f023/Դ.ipch

37.13MB

C++11_Thread/.vs/C++11_Thread/v17/ipch/AutoPCH/b9873508178ebd35/

C++11_Thread/.vs/C++11_Thread/v17/ipch/AutoPCH/b9873508178ebd35/Դ.ipch

41.88MB

C++11_Thread/.vs/C++11_Thread/v17/ipch/AutoPCH/c64412a8f62fb134/

C++11_Thread/.vs/C++11_Thread/v17/ipch/AutoPCH/c64412a8f62fb134/Դ.ipch

42.38MB

C++11_Thread/.vs/C++11_Thread/v17/ipch/AutoPCH/f2ce33fa5c52acbf/

C++11_Thread/.vs/C++11_Thread/v17/ipch/AutoPCH/f2ce33fa5c52acbf/Դ.ipch

42.63MB

C++11_Thread/.vs/C++11_Thread/v17/ipch/AutoPCH/fcaeead4f0a47d08/

C++11_Thread/.vs/C++11_Thread/v17/Solution.VC.db

1.07MB

C++11_Thread/02-数据未定义错误/

C++11_Thread/02-数据未定义错误/02-数据未定义错误.vcxproj

6.48KB

C++11_Thread/02-数据未定义错误/02-数据未定义错误.vcxproj.filters

965B

C++11_Thread/02-数据未定义错误/02-数据未定义错误.vcxproj.user

168B

C++11_Thread/02-数据未定义错误/x64/

C++11_Thread/02-数据未定义错误/x64/Debug/

C++11_Thread/02-数据未定义错误/x64/Debug/02-数据未定义错误.exe.recipe

316B

C++11_Thread/02-数据未定义错误/x64/Debug/02-数据未定义错误.ilk

911.02KB

C++11_Thread/02-数据未定义错误/x64/Debug/02-数据未定义错误.log

224B

C++11_Thread/02-数据未定义错误/x64/Debug/02-数据未定义错误.tlog/

C++11_Thread/02-数据未定义错误/x64/Debug/02-数据未定义错误.tlog/02-数据未定义错误.lastbuildstate

189B

C++11_Thread/02-数据未定义错误/x64/Debug/02-数据未定义错误.tlog/CL.command.1.tlog

832B

C++11_Thread/02-数据未定义错误/x64/Debug/02-数据未定义错误.tlog/Cl.items.tlog

147B

C++11_Thread/02-数据未定义错误/x64/Debug/02-数据未定义错误.tlog/CL.read.1.tlog

18.52KB

C++11_Thread/02-数据未定义错误/x64/Debug/02-数据未定义错误.tlog/CL.write.1.tlog

504B

C++11_Thread/02-数据未定义错误/x64/Debug/02-数据未定义错误.tlog/link.command.1.tlog

1.6KB

C++11_Thread/02-数据未定义错误/x64/Debug/02-数据未定义错误.tlog/link.read.1.tlog

5.35KB

C++11_Thread/02-数据未定义错误/x64/Debug/02-数据未定义错误.tlog/link.write.1.tlog

518B

C++11_Thread/02-数据未定义错误/x64/Debug/vc143.idb

171KB

C++11_Thread/02-数据未定义错误/x64/Debug/vc143.pdb

452KB

C++11_Thread/02-数据未定义错误/x64/Debug/vcpkg.applocal.log

C++11_Thread/02-数据未定义错误/x64/Debug/源.obj

172.22KB

C++11_Thread/02-数据未定义错误/源.cpp

460B

C++11_Thread/03-互斥量解决多线程数据共享问题/

C++11_Thread/03-互斥量解决多线程数据共享问题/03-互斥量解决多线程数据共享问题.vcxproj

6.5KB

C++11_Thread/03-互斥量解决多线程数据共享问题/03-互斥量解决多线程数据共享问题.vcxproj.filters

965B

C++11_Thread/03-互斥量解决多线程数据共享问题/03-互斥量解决多线程数据共享问题.vcxproj.user

168B

C++11_Thread/03-互斥量解决多线程数据共享问题/x64/

C++11_Thread/03-互斥量解决多线程数据共享问题/x64/Debug/

C++11_Thread/03-互斥量解决多线程数据共享问题/x64/Debug/03-互斥量解决.b35ae6aa.tlog/

C++11_Thread/03-互斥量解决多线程数据共享问题/x64/Debug/03-互斥量解决.b35ae6aa.tlog/03-互斥量解决多线程数据共享问题.lastbuildstate

189B

C++11_Thread/03-互斥量解决多线程数据共享问题/x64/Debug/03-互斥量解决.b35ae6aa.tlog/CL.command.1.tlog

860B

C++11_Thread/03-互斥量解决多线程数据共享问题/x64/Debug/03-互斥量解决.b35ae6aa.tlog/Cl.items.tlog

189B

C++11_Thread/03-互斥量解决多线程数据共享问题/x64/Debug/03-互斥量解决.b35ae6aa.tlog/CL.read.1.tlog

18.71KB

C++11_Thread/03-互斥量解决多线程数据共享问题/x64/Debug/03-互斥量解决.b35ae6aa.tlog/CL.write.1.tlog

560B

C++11_Thread/03-互斥量解决多线程数据共享问题/x64/Debug/03-互斥量解决.b35ae6aa.tlog/link.command.1.tlog

1.67KB

C++11_Thread/03-互斥量解决多线程数据共享问题/x64/Debug/03-互斥量解决.b35ae6aa.tlog/link.read.1.tlog

5.62KB

C++11_Thread/03-互斥量解决多线程数据共享问题/x64/Debug/03-互斥量解决.b35ae6aa.tlog/link.write.1.tlog

588B

C++11_Thread/03-互斥量解决多线程数据共享问题/x64/Debug/03-互斥量解决多线程数据共享问题.exe.recipe

337B

C++11_Thread/03-互斥量解决多线程数据共享问题/x64/Debug/03-互斥量解决多线程数据共享问题.ilk

1005.89KB

C++11_Thread/03-互斥量解决多线程数据共享问题/x64/Debug/03-互斥量解决多线程数据共享问题.log

527B

C++11_Thread/03-互斥量解决多线程数据共享问题/x64/Debug/vc143.idb

179KB

C++11_Thread/03-互斥量解决多线程数据共享问题/x64/Debug/vc143.pdb

444KB

C++11_Thread/03-互斥量解决多线程数据共享问题/x64/Debug/vcpkg.applocal.log

C++11_Thread/03-互斥量解决多线程数据共享问题/x64/Debug/源.obj

375.1KB

C++11_Thread/03-互斥量解决多线程数据共享问题/源.cpp

686B

C++11_Thread/04-call_once/

C++11_Thread/04-call_once/04-call_once.vcxproj

6.47KB

C++11_Thread/04-call_once/04-call_once.vcxproj.filters

965B

C++11_Thread/04-call_once/04-call_once.vcxproj.user

168B

C++11_Thread/04-call_once/x64/

C++11_Thread/04-call_once/x64/Debug/

C++11_Thread/04-call_once/x64/Debug/04-call_once.exe.recipe

304B

C++11_Thread/04-call_once/x64/Debug/04-call_once.ilk

889.81KB

C++11_Thread/04-call_once/x64/Debug/04-call_once.log

200B

C++11_Thread/04-call_once/x64/Debug/04-call_once.tlog/

C++11_Thread/04-call_once/x64/Debug/04-call_once.tlog/04-call_once.lastbuildstate

189B

C++11_Thread/04-call_once/x64/Debug/04-call_once.tlog/CL.command.1.tlog

840B

C++11_Thread/04-call_once/x64/Debug/04-call_once.tlog/Cl.items.tlog

123B

C++11_Thread/04-call_once/x64/Debug/04-call_once.tlog/CL.read.1.tlog

18.88KB

C++11_Thread/04-call_once/x64/Debug/04-call_once.tlog/CL.write.1.tlog

520B

C++11_Thread/04-call_once/x64/Debug/04-call_once.tlog/link.command.1.tlog

1.62KB

C++11_Thread/04-call_once/x64/Debug/04-call_once.tlog/link.read.1.tlog

5.57KB

C++11_Thread/04-call_once/x64/Debug/04-call_once.tlog/link.write.1.tlog

538B

C++11_Thread/04-call_once/x64/Debug/vc143.idb

171KB

C++11_Thread/04-call_once/x64/Debug/vc143.pdb

436KB

C++11_Thread/04-call_once/x64/Debug/vcpkg.applocal.log

C++11_Thread/04-call_once/x64/Debug/Դ.obj

206.39KB

C++11_Thread/04-call_once/Դ.cpp

521B

C++11_Thread/05-condition_variable/

C++11_Thread/05-condition_variable/05-condition_variable.vcxproj

6.48KB

C++11_Thread/05-condition_variable/05-condition_variable.vcxproj.filters

965B

C++11_Thread/05-condition_variable/05-condition_variable.vcxproj.user

168B

C++11_Thread/05-condition_variable/x64/

C++11_Thread/05-condition_variable/x64/Debug/

C++11_Thread/05-condition_variable/x64/Debug/05-condi.46cff188.tlog/

C++11_Thread/05-condition_variable/x64/Debug/05-condi.46cff188.tlog/05-condition_variable.lastbuildstate

189B

C++11_Thread/05-condition_variable/x64/Debug/05-condi.46cff188.tlog/CL.command.1.tlog

876B

C++11_Thread/05-condition_variable/x64/Debug/05-condi.46cff188.tlog/Cl.items.tlog

141B

C++11_Thread/05-condition_variable/x64/Debug/05-condi.46cff188.tlog/CL.read.1.tlog

19.82KB

C++11_Thread/05-condition_variable/x64/Debug/05-condi.46cff188.tlog/CL.write.1.tlog

592B

C++11_Thread/05-condition_variable/x64/Debug/05-condi.46cff188.tlog/link.command.1.tlog

1.71KB

C++11_Thread/05-condition_variable/x64/Debug/05-condi.46cff188.tlog/link.read.1.tlog

5.46KB

C++11_Thread/05-condition_variable/x64/Debug/05-condi.46cff188.tlog/link.write.1.tlog

628B

C++11_Thread/05-condition_variable/x64/Debug/05-condition_variable.exe.recipe

313B

C++11_Thread/05-condition_variable/x64/Debug/05-condition_variable.ilk

1.57MB

C++11_Thread/05-condition_variable/x64/Debug/05-condition_variable.log

218B

C++11_Thread/05-condition_variable/x64/Debug/vc143.idb

187KB

C++11_Thread/05-condition_variable/x64/Debug/vc143.pdb

484KB

C++11_Thread/05-condition_variable/x64/Debug/vcpkg.applocal.log

C++11_Thread/05-condition_variable/x64/Debug/Դ.obj

385.64KB

C++11_Thread/05-condition_variable/Դ.cpp

880B

C++11_Thread/06-实现跨平台线程池/

C++11_Thread/06-实现跨平台线程池/06-实现跨平台线程池.vcxproj

6.49KB

C++11_Thread/06-实现跨平台线程池/06-实现跨平台线程池.vcxproj.filters

965B

C++11_Thread/06-实现跨平台线程池/06-实现跨平台线程池.vcxproj.user

168B

C++11_Thread/06-实现跨平台线程池/x64/

C++11_Thread/06-实现跨平台线程池/x64/Debug/

C++11_Thread/06-实现跨平台线程池/x64/Debug/06-实现跨平台线程池.exe.recipe

319B

C++11_Thread/06-实现跨平台线程池/x64/Debug/06-实现跨平台线程池.ilk

1.73MB

C++11_Thread/06-实现跨平台线程池/x64/Debug/06-实现跨平台线程池.log

230B

C++11_Thread/06-实现跨平台线程池/x64/Debug/06-实现跨平台线程池.tlog/

C++11_Thread/06-实现跨平台线程池/x64/Debug/06-实现跨平台线程池.tlog/06-实现跨平台线程池.lastbuildstate

189B

C++11_Thread/06-实现跨平台线程池/x64/Debug/06-实现跨平台线程池.tlog/CL.command.1.tlog

1.67KB

C++11_Thread/06-实现跨平台线程池/x64/Debug/06-实现跨平台线程池.tlog/Cl.items.tlog

153B

C++11_Thread/06-实现跨平台线程池/x64/Debug/06-实现跨平台线程池.tlog/CL.read.1.tlog

19.99KB

C++11_Thread/06-实现跨平台线程池/x64/Debug/06-实现跨平台线程池.tlog/CL.write.1.tlog

512B

C++11_Thread/06-实现跨平台线程池/x64/Debug/06-实现跨平台线程池.tlog/link.command.1.tlog

1.61KB

C++11_Thread/06-实现跨平台线程池/x64/Debug/06-实现跨平台线程池.tlog/link.read.1.tlog

5.36KB

C++11_Thread/06-实现跨平台线程池/x64/Debug/06-实现跨平台线程池.tlog/link.write.1.tlog

528B

C++11_Thread/06-实现跨平台线程池/x64/Debug/ThreadPool.obj

59.25KB

C++11_Thread/06-实现跨平台线程池/x64/Debug/vc143.idb

307KB

C++11_Thread/06-实现跨平台线程池/x64/Debug/vc143.pdb

580KB

C++11_Thread/06-实现跨平台线程池/x64/Debug/vcpkg.applocal.log

C++11_Thread/06-实现跨平台线程池/x64/Debug/源.obj

659.63KB

C++11_Thread/06-实现跨平台线程池/源.cpp

3.33KB

C++11_Thread/07-异步并发/

C++11_Thread/07-异步并发/07-异步并发.vcxproj

6.48KB

C++11_Thread/07-异步并发/07-异步并发.vcxproj.filters

965B

C++11_Thread/07-异步并发/07-异步并发.vcxproj.user

168B

C++11_Thread/07-异步并发/x64/

C++11_Thread/07-异步并发/x64/Debug/

C++11_Thread/07-异步并发/x64/Debug/07-异步并发.exe.recipe

307B

C++11_Thread/07-异步并发/x64/Debug/07-异步并发.ilk

1.18MB

C++11_Thread/07-异步并发/x64/Debug/07-异步并发.log

206B

C++11_Thread/07-异步并发/x64/Debug/07-异步并发.tlog/

C++11_Thread/07-异步并发/x64/Debug/07-异步并发.tlog/07-异步并发.lastbuildstate

189B

C++11_Thread/07-异步并发/x64/Debug/07-异步并发.tlog/CL.command.1.tlog

820B

C++11_Thread/07-异步并发/x64/Debug/07-异步并发.tlog/Cl.items.tlog

129B

C++11_Thread/07-异步并发/x64/Debug/07-异步并发.tlog/CL.read.1.tlog

23.06KB

C++11_Thread/07-异步并发/x64/Debug/07-异步并发.tlog/CL.write.1.tlog

480B

C++11_Thread/07-异步并发/x64/Debug/07-异步并发.tlog/link.command.1.tlog

1.57KB

C++11_Thread/07-异步并发/x64/Debug/07-异步并发.tlog/link.read.1.tlog

5.32KB

C++11_Thread/07-异步并发/x64/Debug/07-异步并发.tlog/link.write.1.tlog

488B

C++11_Thread/07-异步并发/x64/Debug/vc143.idb

203KB

C++11_Thread/07-异步并发/x64/Debug/vc143.pdb

796KB

C++11_Thread/07-异步并发/x64/Debug/vcpkg.applocal.log

C++11_Thread/07-异步并发/x64/Debug/源.obj

394.89KB

C++11_Thread/07-异步并发/源.cpp

695B

C++11_Thread/08-原子操作atomic/

C++11_Thread/08-原子操作atomic/08-原子操作atomic.vcxproj

6.48KB

C++11_Thread/08-原子操作atomic/08-原子操作atomic.vcxproj.filters

965B

C++11_Thread/08-原子操作atomic/08-原子操作atomic.vcxproj.user

168B

C++11_Thread/08-原子操作atomic/x64/

C++11_Thread/08-原子操作atomic/x64/Debug/

C++11_Thread/08-原子操作atomic/x64/Debug/08-原子操作atomic.exe.recipe

313B

C++11_Thread/08-原子操作atomic/x64/Debug/08-原子操作atomic.ilk

840.84KB

C++11_Thread/08-原子操作atomic/x64/Debug/08-原子操作atomic.log

218B

C++11_Thread/08-原子操作atomic/x64/Debug/08-原子操作atomic.tlog/

C++11_Thread/08-原子操作atomic/x64/Debug/08-原子操作atomic.tlog/08-原子操作atomic.lastbuildstate

189B

C++11_Thread/08-原子操作atomic/x64/Debug/08-原子操作atomic.tlog/CL.command.1.tlog

844B

C++11_Thread/08-原子操作atomic/x64/Debug/08-原子操作atomic.tlog/Cl.items.tlog

141B

C++11_Thread/08-原子操作atomic/x64/Debug/08-原子操作atomic.tlog/CL.read.1.tlog

18.53KB

C++11_Thread/08-原子操作atomic/x64/Debug/08-原子操作atomic.tlog/CL.write.1.tlog

528B

C++11_Thread/08-原子操作atomic/x64/Debug/08-原子操作atomic.tlog/link.command.1.tlog

1.63KB

C++11_Thread/08-原子操作atomic/x64/Debug/08-原子操作atomic.tlog/link.read.1.tlog

5.38KB

C++11_Thread/08-原子操作atomic/x64/Debug/08-原子操作atomic.tlog/link.write.1.tlog

548B

C++11_Thread/08-原子操作atomic/x64/Debug/vc143.idb

227KB

C++11_Thread/08-原子操作atomic/x64/Debug/vc143.pdb

732KB

C++11_Thread/08-原子操作atomic/x64/Debug/vcpkg.applocal.log

C++11_Thread/08-原子操作atomic/x64/Debug/源.obj

104.03KB

C++11_Thread/08-原子操作atomic/源.cpp

280B

C++11_Thread/C++11_Thread.sln

6.9KB

C++11_Thread/C++11_Thread/

C++11_Thread/C++11_Thread/C++11_Thread.vcxproj

6.47KB

C++11_Thread/C++11_Thread/C++11_Thread.vcxproj.filters

965B

C++11_Thread/C++11_Thread/C++11_Thread.vcxproj.user

168B

C++11_Thread/C++11_Thread/x64/

C++11_Thread/C++11_Thread/x64/Debug/

C++11_Thread/C++11_Thread/x64/Debug/C++11_Thread.exe.recipe

304B

C++11_Thread/C++11_Thread/x64/Debug/C++11_Thread.ilk

1.13MB

C++11_Thread/C++11_Thread/x64/Debug/C++11_Thread.log

200B

C++11_Thread/C++11_Thread/x64/Debug/C++11_Thread.tlog/

C++11_Thread/C++11_Thread/x64/Debug/C++11_Thread.tlog/C++11_Thread.lastbuildstate

189B

C++11_Thread/C++11_Thread/x64/Debug/C++11_Thread.tlog/CL.command.1.tlog

840B

C++11_Thread/C++11_Thread/x64/Debug/C++11_Thread.tlog/Cl.items.tlog

123B

C++11_Thread/C++11_Thread/x64/Debug/C++11_Thread.tlog/CL.read.1.tlog

18.7KB

C++11_Thread/C++11_Thread/x64/Debug/C++11_Thread.tlog/CL.write.1.tlog

520B

C++11_Thread/C++11_Thread/x64/Debug/C++11_Thread.tlog/link.command.1.tlog

1.62KB

C++11_Thread/C++11_Thread/x64/Debug/C++11_Thread.tlog/link.read.1.tlog

5.37KB

C++11_Thread/C++11_Thread/x64/Debug/C++11_Thread.tlog/link.write.1.tlog

538B

C++11_Thread/C++11_Thread/x64/Debug/vc143.idb

171KB

C++11_Thread/C++11_Thread/x64/Debug/vc143.pdb

452KB

C++11_Thread/C++11_Thread/x64/Debug/vcpkg.applocal.log

C++11_Thread/C++11_Thread/x64/Debug/Դ.obj

253.34KB

C++11_Thread/C++11_Thread/Դ.cpp

317B

C++11_Thread/x64/

C++11_Thread/x64/Debug/

C++11_Thread/x64/Debug/02-数据未定义错误.exe

84KB

C++11_Thread/x64/Debug/02-数据未定义错误.pdb

1.86MB

C++11_Thread/x64/Debug/03-互斥量解决多线程数据共享问题.exe

120.5KB

C++11_Thread/x64/Debug/03-互斥量解决多线程数据共享问题.pdb

1.96MB

C++11_Thread/x64/Debug/04-call_once.exe

89KB

C++11_Thread/x64/Debug/04-call_once.pdb

1.56MB

C++11_Thread/x64/Debug/05-condition_variable.exe

126KB

C++11_Thread/x64/Debug/05-condition_variable.pdb

2.04MB

C++11_Thread/x64/Debug/06-实现跨平台线程池.exe

159KB

C++11_Thread/x64/Debug/06-实现跨平台线程池.pdb

2.76MB

C++11_Thread/x64/Debug/07-异步并发.exe

117.5KB

C++11_Thread/x64/Debug/07-异步并发.pdb

2.13MB

C++11_Thread/x64/Debug/08-原子操作atomic.exe

73.5KB

C++11_Thread/x64/Debug/08-原子操作atomic.pdb

1.86MB

C++11_Thread/x64/Debug/C++11_Thread.exe

92.5KB

C++11_Thread/x64/Debug/C++11_Thread.pdb

2.02MB

资源内容介绍

c++11多线程-从零基础到手撕线程池

#include<iostream>#include<thread>#include<mutex>#include<string>#include<condition_variable>#include<queue>#include<vector>#include<functional>class ThreadPool{public:ThreadPool(int numThreads) : stop(false) {for (int i = 0; i < numThreads; i++) {threads.emplace_back([this]() {while (1) {std::unique_lock<std::mutex> lock(mtx);condition.wait(lock, [this]() {return !tasks.empty() || stop;});if (stop && tasks.empty()) {return;}std::function<void()> task(std::move(tasks.front()));tasks.pop();lock.unlock();task();}});}}~ThreadPool() {{std::unique_lock<std::mutex> lock(mtx);stop = true;}condition.notify_all();for (auto& t : threads) {t.join();}}template<class T, class... Args>void enqueue(T&& t, Args&&... args) {std::function<void()> task =std::bind(std::forward<T>(t), std::forward<Args>(args)...);{std::unique_lock<std::mutex> lock(mtx);tasks.emplace(std::move(task));}condition.notify_one();}private:std::vector<std::thread> threads;std::queue<std::function<void()>> tasks;std::mutex mtx;std::condition_variable condition;bool stop;};class ThreadPoolSingleton{public:ThreadPoolSingleton(const ThreadPoolSingleton&) = delete;ThreadPoolSingleton& operator=(const ThreadPoolSingleton&) = delete;static ThreadPoolSingleton& getInstance() {static ThreadPoolSingleton instance;return instance;}template<class T, class... Args>void enqueue(T&& t, Args&&... args) {std::function<void()> task =std::bind(std::forward<T>(t), std::forward<Args>(args)...);{std::unique_lock<std::mutex> lock(mtx);tasks.emplace(std::move(task));}condition.notify_one();}private:ThreadPoolSingleton() : stop(false) {int numThreads = std::thread::hardware_concurrency(); // 硬件支持的线程数for (int i = 0; i < numThreads; i++) {threads.emplace_back([this]() {while (1) {std::unique_lock<std::mutex> lock(mtx);condition.wait(lock, [this]() {return !tasks.empty() || stop;});if (stop && tasks.empty()) {return;}std::function<void()> task(std::move(tasks.front()));tasks.pop();lock.unlock();task();}});}}~ThreadPoolSingleton() {{std::unique_lock<std::mutex> lock(mtx);stop = true;}condition.notify_all();for (auto& t : threads) {t.join();}}std::vector<std::thread> threads;std::queue<std::function<void()>> tasks;std::mutex mtx;std::condition_variable condition;bool stop;};int main() {//ThreadPool pool(4);//for (int i = 0; i < 10; i++) {//pool.enqueue([i]() {//std::cout << "任务：" << i << "正在运行" << std::endl;//std::this_thread::sleep_for(std::chrono::seconds(1));//std::cout << "任务：" << i << "结束运行" << std::endl;//});//}ThreadPoolSingleton::getInstance();for (int i = 0; i < 10; i++) {ThreadPoolSingleton::getInstance().enqueue([i]() {std::cout << "任务：" << i << "正在运行" << std::endl;std::this_thread::sleep_for(std::chrono::seconds(1));std::cout << "任务：" << i << "结束运行" << std::endl;});}return 0;}

用户评论 (0)

发表评论

您的昵称:

评分

评论内容:

验证码:

c++11多线程-从零基础到手撕线程池

资源文件列表(大概)

资源内容介绍

用户评论 (0)

发表评论

相关资源

在线民谣网站 JAVA+Vue.js+SpringBoot+MySQL

银行账目管理系统 JAVA+Vue.js+SpringBoot+MySQL

丁丁串口调试助手 SSCOM

民宿管理系统 JAVA+Vue.js+SpringBoot+MySQL