VB.net 2010 视频教程 VB.net 2010 视频教程 python基础视频教程
SQL Server 2008 视频教程 c#入门经典教程 Visual Basic从门到精通视频教程
当前位置:
首页 > 编程开发 > Python基础教程 >
  • python基础教程之python进程池和进程锁

本站最新发布   Python从入门到精通|Python基础教程
试听地址  
https://www.xin3721.com/eschool/pythonxin3721/


1.进程锁:
from multiprocessing import Process, Lock

def f(l, i):
  l.acquire()
  print('hello world', i)
  l.release()

if __name__ == '__main__':
  lock = Lock()

for num in range(10):
  Process(target=f, args=(lock, num)).start()

2.进程池:
from multiprocessing import Pool
import time

def Foo(i):
  time.sleep(2)
  print(i+100)

#允许进程池里同时放入5个进程
pool = Pool(5)
for i in range(10):
  #并行执行
  pool.apply_async(func=Foo,args=(i,))

pool.close()
pool.join() #进程池中进程执行完毕后再关闭,如果注释,那么程序直接关闭。

print('end')


3.进程池与进程锁:
from multiprocessing import Pool, Manager
import time

def Foo(i, l):
  l.acquire()
  time.sleep(2)
  print(i+100)
  l.release()

lock = Manager().Lock()
#允许进程池里同时放入5个进程
pool = Pool(5)
for i in range(10):
  #并行执行
  pool.apply_async(func=Foo,args=(i, lock, ))

pool.close()
pool.join() #进程池中进程执行完毕后再关闭,如果注释,那么程序直接关闭。

print('end')

相关教程