《Python标准库》thread多线程同步互斥部分疑惑探讨求解

chx27

周末阅读《Python标准库》一书的threading部分，以我vxworks为主的c语言开发经验，对标准库中的task同步互斥理解有些疑问，不得要领。
在此把我的疑惑讲出来，求得各位有何见解和真知。

案例代码:
1.1同步线程 使用 condition

1. logging.basicConfig(
   
2.     level=logging.DEBUG,
   
3.     format='%(asctime)s (%(threadName)-2s) %(message)s',
   
4.     )
   
5. 
   
6. def consumer(cond):
   
7.     """wait for the condition and use the resource"""
   
8.     logging.debug('Starting consumer thread')
   
9.     t = threading.currentThread()
   
10.     [color=Red]with cond:[/color]
    
11.         [color=Red]cond.wait()[/color]
    
12.         logging.debug('Resource is available to consumer')
    
13. 
    
14. def producer(cond):
    
15.     """set up the resource to be used by the consumer"""
    
16.     logging.debug('Starting producer thread')
    
17.     [color=Red]with cond:[/color]
    
18.         logging.debug('Making resource available')
    
19.         [color=Red]cond.notifyAll()[/color]
    
20. 
    
21. condition = threading.Condition()
    
22. c1 = threading.Thread(name='c1', target=consumer,
    
23.                       args=(condition,))
    
24. c2 = threading.Thread(name='c2', target=consumer,
    
25.                       args=(condition,))
    
26. p = threading.Thread(name='p', target=producer,
    
27.                      args=(condition,))
    
28. 
    
29. c1.start()
    
30. time.sleep(2)
    
31. c2.start()
    
32. time.sleep(2)
    
33. p.start()

复制代码

1.2线程间传递信号 使用event

1. logging.basicConfig(level=logging.DEBUG,
   
2.                     format='(%(threadName)-10s) %(message)s',
   
3.                     )
   
4.                     
   
5. def wait_for_event(e):
   
6.     """Wait for the event to be set before doing anything"""
   
7.     logging.debug('wait_for_event starting')
   
8.     event_is_set = [color=Red]e.wait()[/color]
   
9.     logging.debug('event set: %s', event_is_set)
   
10. 
    
11. def wait_for_event_timeout(e, t):
    
12.     """Wait t seconds and then timeout"""
    
13.     while not e.isSet():
    
14.         logging.debug('wait_for_event_timeout starting')
    
15.         event_is_set = e.wait(t)
    
16.         logging.debug('event set: %s', event_is_set)
    
17.         if event_is_set:
    
18.             logging.debug('processing event')
    
19.         else:
    
20.             logging.debug('doing other work')
    
21. 
    
22. 
    
23. e = threading.Event()
    
24. t1 = threading.Thread(name='block',
    
25.                       target=wait_for_event,
    
26.                       args=(e,))
    
27. t1.start()
    
28. 
    
29. t2 = threading.Thread(name='nonblock',
    
30.                       target=wait_for_event_timeout,
    
31.                       args=(e, 2))
    
32. t2.start()
    
33. 
    
34. logging.debug('Waiting before calling Event.set()')
    
35. time.sleep(3)
    
36. [color=Red]e.set()[/color]
    
37. logging.debug('Event is set')

复制代码

疑问：
我初略理解为condition就是lock+event。
所以同步线程采用的代码结构是

1.     with cond:
   
2.         cond.wait()
   
3. 与
   
4.     with cond:
   
5.         cond.notifyAll()

复制代码

而线程间传递信号的代码结构是

1. e.wait()
   
2. 与
   
3. e.set()

复制代码

我觉得cond用法中的lock是重复的，反正就需要cond.wait了（忽略e.set()和cond.notifyAll()的细微差别）。我还要with cond（请求锁）干什么呢。
就像vxworks中semTake()和semGive()一样。这个cond.wait()天生就是包含了阻塞等待的意思。