python manager是进程安全的么_Python在进程之间共享锁

抱歉，我应该已经回答您其他问题了。您不能将普通multiprocessing.Lock对象传递给Pool方法，因为它们不能被腌制。有两种方法可以解决此问题。一种是创建Manager()并传递一个Manager.Lock()：

def main():

iterable = [1, 2, 3, 4, 5]

pool = multiprocessing.Pool()

m = multiprocessing.Manager()

l = m.Lock()

func = partial(target, l)

pool.map(func, iterable)

pool.close()

pool.join()

不过，这有点重量级；使用Manager需要产生另一个进程来托管Manager服务器。并且所有对acquire/ release锁的调用都必须通过IPC发送到该服务器。

另一个选择是multiprocessing.Lock()使用initializerkwarg 在创建池时传递常规值。这将使您的锁实例在所有子工作者中都是全局的：

def target(iterable_item):

for item in items:

# Do cool stuff

if (... some condition here ...):

lock.acquire()

# Write to stdout or logfile, etc.

lock.release()

def init(l):

global lock

lock = l

def main():

iterable = [1, 2, 3, 4, 5]

l = multiprocessing.Lock()

pool = multiprocessing.Pool(initializer=init, initargs=(l,))

pool.map(target, iterable)

pool.close()

pool.join()

第二种解决方案具有不再需要的副作用partial。

python manager是进程安全的么_Python在进程之间共享锁相关推荐

python的线程如何启用和结束_python线程进程
操作系统一为什么要有操作系统? 现代计算机系统是由一个或者多个处理器,主存,磁盘,打印机,键盘,鼠标显示器,网络接口以及各种其他输入输出设备组成的复杂系统,每位程序员不可能掌握所有系统实现的细节 ...
python 结束进程快捷键是什么_python结束进程的方式有什么
python退出程序的方式 python程序退出方式[sys.exit() os._exit() os.kill() os.popen(...)] 1. sys.exit() 执行该语句会直接退出程序 ...
python求1到100偶数和_python 求1-100之间的奇数或者偶数之和的实例
python 求1-100之间的奇数或者偶数之和的实例如下所示: i=0 sum1=0 sum2=0 while i<=100: if i%2==0: sum1+=i else: sum2+= ...
python manager详解_Python通过Manager方式实现多个无关联进程共享数据
Python官方文档 Python实现多进程间通信的方式有很多种,例如队列,管道等. 但是这些方式只适用于多个进程都是源于同一个父进程的情况. 如果多个进程不是源于同一个父进程,只能用共享内存,信号量 ...
python进程池调用实例方法_Python进程池Pool应用实例分析
本文实例讲述了Python进程池Pool应用.分享给大家供大家参考,具体如下: 当需要创建的子进程数量不多时,可以直接利用multiprocessing中的Process动态成生多个进程,但如果是上百 ...
python打开一个软件并进行操作_python程序中的进程操作
之前我们已经了解了很多进程相关的理论知识,了解进程是什么应该不再困难了,刚刚我们已经了解了,运行中的程序就是一个进程.所有的进程都是通过它的父进程来创建的.因此,运行起来的python程序也是一个进程 ...
python进程和线程是什么_python的进程与线程
一.进程与线程的相关概念 1.什么是进程进程是一个程序在一个数据集上的一次动态执行过程. 进程一般由程序,数据集,进程控制块三部分组成. 2.什么是线程线程也叫轻量级进程,它是一个基本的CPU执行 ...
python的进程池map函数_python进程池map
python进程池怎么实现当进程池中任务队列非空时,才会触发worker进程去工作,那么如何向进程池中的任务队列中添加任务呢,进程池类有两组关键方法来创建任务,分别是apply/apply_asyn ...
python多线程执行其他模块的文件_python并发编程--进程线程--其他模块-从菜鸟到老鸟（三）...
concurrent模块 1.concurrent模块的介绍 concurrent.futures模块提供了高度封装的异步调用接口 ThreadPoolExecutor:线程池,提供异步调用 Proc ...

python manager是进程安全的么_Python在进程之间共享锁

python manager是进程安全的么_Python在进程之间共享锁相关推荐

最新文章

热门文章