設(shè)想這樣一個場景：

創(chuàng)新互聯(lián)建站于2013年成立，先為奇臺等服務(wù)建站，奇臺等地企業(yè)，進行企業(yè)商務(wù)咨詢服務(wù)。為奇臺企業(yè)網(wǎng)站制作PC+手機+微官網(wǎng)三網(wǎng)同步一站式服務(wù)解決您的所有建站問題。

你創(chuàng)建了10個子線程，每個子線程分別爬一個網(wǎng)站，一開始所有子線程都是阻塞等待。一旦某個事件發(fā)生：例如有人在網(wǎng)頁上點了一個按鈕，或者某人在命令行輸入了一個命令，10個爬蟲同時開始工作。

肯定有人會想到用Redis來實現(xiàn)這個開關(guān)：所有子線程全部監(jiān)控Redis中名為start_crawl的字符串，如果這個字符串不存在，或者為0，那么就等待1秒鐘，再繼續(xù)檢查。如果這個字符串為1，那么就開始運行。

代碼片段可以簡寫為：

 
 
 
 

  
  
  
  
import time
  
  
  
  
import redis
  
  
  
  

  
  
  
  
client = redis.Redis()
  
  
  
  
while client.get('start_crawl') != 1:
  
  
  
  
    print('繼續(xù)等待')
  
  
  
  
    time.sleep(1)
 
 
 
 

這樣做確實可以達到目的，不過每一個子線程都會頻繁檢查Redis。

實際上，在Python的多線程中，有一個Event模塊，天然就是用來實現(xiàn)這個目的的。

Event是一個能在多線程中共用的對象，一開始它包含一個為False的信號標(biāo)志，一旦在任一一個線程里面把這個標(biāo)記改為True，那么所有的線程都會看到這個標(biāo)記變成了True。

我們通過一段代碼來說明它的使用方法：

 
 
 
 

  
  
  
  
import threading
  
  
  
  
import time
  
  
  
  

  
  
  
  
class spider(threading.Thread):
  
  
  
  
    def __init__(self, n, event):
  
  
  
  
        super().__init__()
  
  
  
  
        self.n = n
  
  
  
  
        self.event = event
  
  
  
  

  
  
  
  
    def run(self):
  
  
  
  
        print(f'第{self.n}號爬蟲已就位！')
  
  
  
  
        self.event.wait()
  
  
  
  
        print(f'信號標(biāo)記變?yōu)門rue?。〉趝self.n}號爬蟲開始運行')
  
  
  
  

  
  
  
  
eve = threading.Event()
  
  
  
  
for num in range(10):
  
  
  
  
    crawler = spider(num, eve)
  
  
  
  
    crawler.start()
  
  
  
  

  
  
  
  
input('按下回車鍵，啟動所有爬蟲！')
  
  
  
  
eve.set()
  
  
  
  
time.sleep(10)
 
 
 
 

運行效果如下圖所示：

在這段代碼中，線程spider在運行以后，會運行到self.event.wait()這一行，然后10個子線程會全部阻塞在這里。而這里的self.event，就是主線程中eve = threading.Event()生成的對象傳入進去的。

在主線程里面，當(dāng)執(zhí)行了eve.set()后，所有子線程的阻塞會被同時解除，于是子線程就可以繼續(xù)運行了。

本文轉(zhuǎn)載自微信公眾號「未聞Code」，可以通過以下二維碼關(guān)注。轉(zhuǎn)載本文請聯(lián)系未聞Code公眾號。

分享名稱：一日一技：Python多線程的事件監(jiān)控
標(biāo)題來源：http://uogjgqi.cn/article/ccdsscg.html