dawei
1，进程可以无限开吗？
进程不可以无限开，cpu有十六核，代表可以同时处理16个任务，如果有160个进程，每个进程
处理需要0.01s，16核的处理器处理160个进程就需要0.5s，因为进程越多需要的时间越多。
2，进程池
multiprocessing multiprocessing += 1
== = Pool(5)
start =1000))
p.close()
(time.time() -== i range(1000= Process(target=func,args=(i,))
i (time.time() – start)
3,
multiprocessing
<span style=”color: #0000ff”>def<span style=”color: #000000″> func(i):
time.sleep(1<span style=”color: #000000″>)
i += 1
<span style=”color: #008000″>#<span style=”color: #008000″> print(i)
<span style=”color: #0000ff”>return i+1
<span style=”color: #0000ff”>if <span style=”color: #800080″>name == <span style=”color: #800000″>'<span style=”color: #800000″>main<span style=”color: #800000″>'<span style=”color: #000000″>:
p = Pool(5<span style=”color: #000000″>)
res_l =<span style=”color: #000000″> []
<span style=”color: #0000ff”>for i <span style=”color: #0000ff”>in range(20<span style=”color: #000000″>):
<span style=”color: #008000″>#<span style=”color: #008000″> p.apply(func,)) # apply是同步提交任务的机制
res = p.apply_async(func,)) <span style=”color: #008000″>#<span style=”color: #008000″> apply_async是异步提交任务的机制
<span style=”color: #000000″> res_l.append(res)
<span style=”color: #008000″>#<span style=”color: #008000″> print(res.get()) # 阻塞 ：等待着任务结果
p.close() <span style=”color: #008000″>#<span style=”color: #008000″> close必须加在join，不允许再添加新的任务了
p.join() <span style=”color: #008000″>#<span style=”color: #008000″> 等待子进程结束再往下执行
[<span style=”color: #0000ff”>print(i.get()) <span style=”color: #0000ff”>for i <span style=”color: #0000ff”>in res_l]
