Python之Monitor監控線程（干貨）

在日常工作中常遇到這樣的情況，我們需要一個監控線程用於隨時的獲得其他進程的任務請求，或者我們需要監視某些資源等的變化，一個高效的Monitor程序如何使用python語言實現呢？為了解決上述問題，我將我所使用的Monitor程序和大家分享，見代碼：

import threading
import random
import time
import sys

class MonitorThread(threading.Thread):
    def __init__(self, event):
        threading.Thread.__init__(self)
        self.threadEvent = event

    def run(self):
        print 'Monitor is ready.\n'
        while True:
            if self.threadEvent.isSet():
                print 'Monitor is running...\n'
                time.sleep(.1)
            else:
                print 'Monitor is stopped.\n'
                break

def main():
    count = 60
    cnf = 0
    event = threading.Event()
    while count >= 0:
        print 'There are %s tasks in queue!' % str(cnf)
        count -= 1
        num = random.randint(1, 100)
        if num%5 == 0:
            if cnf == 0:
                event.set()
                t = MonitorThread(event)
                t.start()
            cnf += 1
        elif num%3 == 0 and num%15 != 0:
            if cnf >= 1:
                event.clear()
                time.sleep(2)
            if cnf >= 1:
                cnf -= 1
    time.sleep(5)
    if cnf >= 1:
        event.clear()

if __name__ == '__main__':
    sys.exit(main())

上述程序會循環60次，每次產生的隨機數如果能夠被5整除，如果已經有monitor線程在運行，則對計數器cnf進行++的操作，否則會啟動一個monitor線程；如果產生的隨機數能夠被3整除而不能被5整除，則會terminate當前monitor線程，對cnf進行--操作！

程序所模擬的就是是否有任務請求，cnf用來記錄當前請求的任務有那些，在我們的實際程序中，我們可以修改上述代碼，增加一個等待隊列用於記錄請求但未得到調用的任務，而event.clear()之前我們則可以對得到請求申請的任務進行處理，當前任務結束調用之后再進行clear操作。

感謝閱讀，希望能夠幫到大家！