使用with语法_Python并行编程

Python从2.5版本开始引入了 with 语法。此语法非常实用，在有两个相关的操作需要在一部分代码块前后分别执行的时候，可以使用 with 语法自动完成。同事，使用 with语法可以在特定的地方分配和释放资源，因此，with语法也叫做“上下文管理器”。在threading模块中，所有带有acquire()方法和release() 方法的对象都可以使用上下文管理器。

也就是说，下面的对象可以使用 with 语法：

Lock
RLock
Condition
Semaphore

1. 准备工作

在本节中，我们将使用 with 语法简单地尝试这四个对象。

2. 如何做…

下面的例子展示了 with 语法的基本用法，我们有一系列的同步原语，下面尝试用 with 来使用它们：

import threading
import logging
logging.basicConfig(level=logging.DEBUG, format='(%(threadName)-10s) %(message)s',)
def threading_with(statement):
    with statement:
        logging.debug('%s acquired via with' % statement)
def threading_not_with(statement):
    statement.acquire()
    try:
        logging.debug('%s acquired directly' % statement )
    finally:
        statement.release()
if __name__ == '__main__':
    # let's create a test battery
    lock = threading.Lock()
    rlock = threading.RLock()
    condition = threading.Condition()
    mutex = threading.Semaphore(1)
    threading_synchronization_list = [lock, rlock, condition, mutex]
    # in the for cycle we call the threading_with e threading_no_with function
    for statement in threading_synchronization_list :
       t1 = threading.Thread(target=threading_with, args=(statement,))
       t2 = threading.Thread(target=threading_not_with, args=(statement,))
       t1.start()
       t2.start()
       t1.join()
       t2.join()

下图展示了使用 with 的每一个函数以及用在了什么地方：

3. 讨论

在主程序中，我们定义了一个list， threading_synchronization_list ，包含要测试的线程同步使用的对象：

lock = threading.Lock()
rlock = threading.RLock()
condition = threading.Condition()
mutex = threading.Semaphore(1)
threading_synchronization_list = [lock, rlock, condition, mutex]

定义之后，我们可以在 for 循环中测试每一个对象：

for statement in threading_synchronization_list :
   t1 = threading.Thread(target=threading_with, args=(statement,))
   t2 = threading.Thread(target=threading_not_with, args=(statement,))

最后，我们有两个目标函数，其中 threading_with 测试了 with 语法：

def threading_with(statement):
    with statement:
        logging.debug('%s acquired via with' % statement)

4. 了解更多

在本例中，我们使用了Python的logging模块进行输出：

logging.basicConfig(level=logging.DEBUG, format='(%(threadName)-10s) %(message)s',)

使用 % (threadName) 可以在每次输出的信息都加上线程的名字。logging模块是线程安全的。这样我们可以区分出不同线程的输出。

译者注：译者在博客上写过一篇有关Python的with语句的文章，可以参考一下：https://www.kawabangga.com/posts/2010