import threadpool
调用sum函数求和
def sum(start, end):
sum = 0
for i in range(start, end + 1):
sum += i
return sum
定义结果统一回调
totalsum = 0
def onresult(req, sum):
global totalsum
totalsum += sum
并发10条线程并求和
def threadpoolSum():
# 创建需求列表
reqlist = []
for i in range(10):
reqlist.append(([i * 10 ** 7 + 1, 10 ** 7 * (i + 1)], None))
reqs = threadpool.makeRequests(sum, reqlist, callback=onresult)
# 创建线程为10的线程池
mypool = threadpool.ThreadPool(10)
for item in reqs:
mypool.putRequest(item)
# 阻塞等待
mypool.wait()
# 打印结果
print(totalsum)
程序主入口
if name == 'main':
threadpoolSum()
-----------------------------------------------进程池
import multiprocessing
调用sum函数求和
def sum(start, end):
sum = 0
for i in range(start, end + 1):
sum += i
return sum
结果统一回调并处理
totalsum = 0
def onresult(sum):
global totalsum
totalsum += sum
def MultiprocessPoolSum():
# 创建10条进程池
mypool = multiprocessing.Pool(10)
for i in range(10):
mypool.apply_async(sum, (i * 10 ** 7 + 1, 10 ** 7 * (i + 1)), callback=onresult)
mypool.close()
mypool.join()
print(totalsum)
程序主入口
if name == 'main':
MultiprocessPoolSum()
