标签：__ 进程同步 Lock 进程 pool print apply foo Pool

import multiprocessing, time, os
'''进程同步Lock'''
# def foo(l, i):
#  l.acquire()
#  print('hello world %s' % i)
#  l.release()
#
# if __name__ == '__main__':
#  l = multiprocessing.Lock() # 也是Lock锁
#  l1 = []
#  for i in range(10):
#     p = multiprocessing.Process(target=foo, args=(l, i,))
#     p.start()
#     l1.append(p)
#  for t in l1:
#     t.join()


'''
进程池Pool:
内部维护一个进程序列，当使用时，则去进程池中获取一个进程，如果进程池序列中没有可供使用的进程，那么程序就会等待，直到进程池中有可用进程为止。
'''
def foo(n):
   time.sleep(1)
   print(n)
   return 'foo %s' % n

def bar(m):
   '''bar函数为回调函数，那么foo的返回值会作为参数传给bar函数，bar函数可用来打印日志'''
   print(m)
   # print('hello')
   # print('two:', os.getpid())
   # print('two:', os.getppid())

if __name__ == '__main__':
   pool = multiprocessing.Pool(5) # 参数5进程池数量，如果为空则默认使用的是本机核数
   # print('one:', os.getpid())
   # print('one:', os.getppid())
   for x in range(100):
      # pool.apply(func=foo, args=(x,)) # apply()同步接口，apply和apply_async直接创建了子进程
      # pool.apply_async(func=foo, args=(x,))
      pool.apply_async(func=foo, args=(x,), callback=bar)
      # callback回调函数，就是某个动作或者函数执行成功后再去执行的函数；主进程创建子进程，callback回调函数是由主进程执行的，通过打印进程号就可发现
   pool.close()
   pool.join() # 必须是先close后join，这是固定顺序
   print('end')

标签：__,进程同步,Lock,进程,pool,print,apply,foo,Pool
来源： https://www.cnblogs.com/xuewei95/p/14865993.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。