在Python中正确使用互斥锁

Question

我从python中的多线程开始（或者至少我的脚本有可能创建多个线程）。该算法是否是Mutex的正确用法？我尚未测试此代码，它可能甚至无法正常工作。我只希望processData在一个线程中运行（一次一个），而主while循环保持运行，即使队列中有一个线程也是如此。

from threading import Thread
from win32event import CreateMutex
mutex = CreateMutex(None, False, "My Crazy Mutex")
while(1)
    t = Thread(target=self.processData, args=(some_data,))
    t.start()
    mutex.lock()

def processData(self, data)
    while(1)
        if mutex.test() == False:
            do some stuff
            break

编辑：重新阅读我的代码，我可以看到它是完全错误的。但是，这就是为什么我在这里寻求帮助。

Answer 1

我不知道您为什么要使用Window的Mutex而不是Python的Mutex。使用Python方法，这非常简单：

from threading import Thread, Lock

mutex = Lock()

def processData(data):
    mutex.acquire()
    try:
        print('Do some stuff')
    finally:
        mutex.release()

while True:
    t = Thread(target = processData, args = (some_data,))
    t.start()

但是请注意，由于CPython的体系结构（即Global Interpreter
Lock
），无论如何一次您实际上只能运行一个线程-
如果其中许多线程受I / O约束，这很好，尽管您会想要释放尽可能多的锁，以便I / O绑定线程不会阻止其他线程运行。

对于Python
2.6和更高版本，一种替代方法是使用Python的multiprocessing软件包。它镜像了threading程序包，但是将创建 可以
同时运行的全新进程。更新您的示例很简单：

from multiprocessing import Process, Lock

mutex = Lock()

def processData(data):
    with mutex:
        print('Do some stuff')

if __name__ == '__main__':
    while True:
        p = Process(target = processData, args = (some_data,))
        p.start()