python – 用获取和释放信号量方法替换关键字

#!/bin/env python

import multiprocessing
from time import sleep
import os

max_allowed_processes_in_critical_section=1
semaphore = multiprocessing.Semaphore(max_allowed_processes_in_critical_section)

def do_job(id):
    # BEGINNING OF CRITICAL SECTION
    with semaphore:
        sleep(1)
        print "#####################"
        print "Inside locked semaphore"
        print "PPID: %s" % os.getppid()
        print "PID:  %s" % os.getpid()

    # END OF CRITICAL SECTION
    print("Finished job")

def main():
    pool = multiprocessing.Pool(6)
    for job_id in range(6):
        print("Starting job")
        pool.apply_async(do_job,[job_id])
    pool.close()
    pool.join()

if __name__ == "__main__":
    main()

正如您在此上下文中所看到的,信号量与关键字一起使用.通常,信号量有两种方法wait()和signal().在python的线程和多处理模块中,这些方法是AFAIK,相当于acquire()和release().我已经重写了这个代码,它使用了acquire()和release()方法：

#!/bin/env python

import multiprocessing
from time import sleep
import os

max_allowed_processes_in_critical_section=1
semaphore = multiprocessing.Semaphore(max_allowed_processes_in_critical_section)

def do_job(id):
    # BEGINNING OF CRITICAL SECTION
    semaphore.acquire()
    sleep(1)
    print "#####################"
    print "Inside locked semaphore"
    print "PPID: %s" % os.getppid()
    print "PID:  %s" % os.getpid()
    semaphore.release()

    # END OF CRITICAL SECTION
    print("Finished job")

def main():
    pool = multiprocessing.Pool(6)
    for job_id in range(6):
        print("Starting job")
        pool.apply_async(do_job,[job_id])
    pool.close()
    pool.join()

if __name__ == "__main__":
    main()

从我之前的question中我了解到,当某个方法与with关键字一起使用时,__enter __()和__exit __()上下文管理器的方法将在with语句的主体上进行调用(并分别退出).所以我假设在__enter __()中调用acquire(),在__exit __()中调用release().

问题：

>我的假设是从__enter __()和中调用acquire()
release()来自__exit __()是否正确？
>在这个例子中,我能以某种方式看到__enter __()和__exit __()方法吗？我还注意到,当我使用版本I访问未定义的变量时,我没有得到任何异常(它必须有一些异常处理,它只是简单地抑制了错误).

例如.即使ppid和pid不存在,这个也不会抛出异常

print "#####################"
print "Inside locked semaphore"
print "PPID: %s" % ppid
print "PID:  %s" % pid

>这种使用信号量的方法是否确保关键部分中一个过程的排他性是正确的？
>作为一个python初学者,我没有理解为什么BoundedSemaphore([value])和Semaphore([value])嵌套在documentation中的类multiprocessing.managers.SyncManager下你能澄清一下吗？