from multiprocessing import Pool
import os,time
import multiprocessing
def func(msg):
print("msg:", msg)
time.sleep(3)
print("end")
return "done" + msg
#使用进程池，异步调用
# if __name__ == "__main__":
# pool = multiprocessing.Pool(processes = 3)
# result=[]
# for i in range(6):
# msg = "hello %d" %(i)
# result.append(pool.apply_async(func, (msg, )))
#
# print("Mark~ Mark~ Mark~~~~~~~~~~~~~~~~~~~~~~")
# pool.close()
# pool.join()
# print(result)#<multiprocessing.pool.ApplyResult object at 0x0000027826D1F160>
# for res in result:
# print(res.get())
# print("Sub-process(es) done.")
'''
Mark~ Mark~ Mark~~~~~~~~~~~~~~~~~~~~~~
msg: hello 0
msg: hello 1
msg: hello 2
end
msg: hello 3
end
end
msg: hello 4
msg: hello 5
end
end
end
[<multiprocessing.pool.ApplyResult object at 0x0000027826D1F160>]
donehello 0
donehello 1
donehello 2
donehello 3
donehello 4
donehello 5
Sub-process(es) done.
'''
#使用进程池，同步调用
if __name__ == "__main__":
pool = multiprocessing.Pool(processes = 3)
result=[]
for i in range(6):
msg = "hello %d" %(i)
result.append(pool.apply(func, (msg, )))
print("Mark~ Mark~ Mark~~~~~~~~~~~~~~~~~~~~~~")
pool.close()
pool.join()
print(result)#
print("Sub-process(es) done.")
'''
msg: hello 0
end
msg: hello 1
end
msg: hello 2
end
msg: hello 3
end
msg: hello 4
end
msg: hello 5
end
Mark~ Mark~ Mark~~~~~~~~~~~~~~~~~~~~~~
['donehello 0', 'donehello 1', 'donehello 2', 'donehello 3', 'donehello 4', 'donehello 5']
Sub-process(es) done.
'''
