1、線程間的信號

  雖然我們使用多線程是為了同時運行多個操作海蔽，不過有時我們也需要同步它們。在線程間安全通信的方式可以使用事件對象史隆。每個 Event （事件）內(nèi)部都有一個標記孔祸，我們可以用 set() 和 clear() 方法控制它。其他線程可以使用 wait() 來暫停直到標記被設置才重新啟動晴竞，使用這方法可以有效阻塞執(zhí)行。

def wait_for_event(e):
    """做任何事前先等待事件被設置狠半。"""
    logging.debug('wait_for_event starting')
    # 一直阻塞直到事件被設置
    event_is_set = e.wait()
    logging.debug('event set: %s', event_is_set)


def wait_for_event_timeout(e, t):
    """等待 t 秒噩死。"""
    while not e.is_set():
        logging.debug('wait_for_event_timeout starting')
        event_is_set = e.wait(t)
        logging.debug('event set: %s', event_is_set)
        if event_is_set:
            logging.debug('processing event')
        else:
            logging.debug('doing other work')


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

e = threading.Event()
t1 = threading.Thread(
    name='block',
    target=wait_for_event,
    args=(e,),
)
t1.start()

t2 = threading.Thread(
    name='nonblock',
    target=wait_for_event_timeout,
    args=(e, 2),
)
t2.start()

logging.debug('Waiting before calling Event.set()')
time.sleep(5)
e.set()
logging.debug('Event is set')

2、控制資源訪問

  除了同步多個線程的操作神年，控制共享資源的訪問以防止污染或丟失數(shù)據(jù)也是非常重要的已维。 Python 的內(nèi)置數(shù)據(jù)結(jié)構(gòu)（列表（list），字典（dict）等....）都是線程安全的已日，有「原子操作」的對象都是這樣垛耳。（全局解釋器鎖會保護這樣的 Python 內(nèi)部數(shù)據(jù)結(jié)構(gòu)在更新時線程不會被釋放）。其他 Python 的數(shù)據(jù)結(jié)構(gòu)或者說較簡單的類型如整數(shù)浮點數(shù)則不會受此保護。我們可以使用 Lock 對象來保護某對象的訪問艾扮。

import logging
import random
import threading
import time

class Counter:

    def __init__(self, start=0):
        self.lock = threading.Lock()
        self.value = start

    def increment(self):
        logging.debug('Waiting for lock')
        self.lock.acquire()
        try:
            logging.debug('Acquired lock')
            self.value = self.value + 1
        finally:
            self.lock.release()

def worker(c):
    for i in range(2):
        pause = random.random()
        logging.debug('Sleeping %0.02f', pause)
        time.sleep(pause)
        c.increment()
    logging.debug('Done')

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

counter = Counter()
for i in range(2):
    t = threading.Thread(target=worker, args=(counter,))
    t.start()

logging.debug('Waiting for worker threads')
main_thread = threading.main_thread()
for t in threading.enumerate():
    if t is not main_thread:
        t.join()
logging.debug('Counter: %d', counter.value)