實現單線程服務器/守護進程（Python）

Question

我正在開發一個服務器（守護進程）。

服務器有一個「工作者線程」。工作線程運行一系列命令。當隊列爲空時，工作線程暫停（但不會退出，因爲它應該保留內存中的某個狀態）。要在內存中擁有完全一個狀態的副本，我需要全部運行一個（不是幾個而不是零）工作線程。

當客戶端連接到Unix套接字併發送命令時，將請求添加到此隊列的末尾。

命令發出後，它被添加到工作線程的命令隊列中。將它添加到隊列後，服務器回覆「OK」之類的內容。服務器接收命令和「確定」回覆之間應該沒有很長的停頓時間。但是，在隊列中運行命令可能需要一些時間。

工作者線程的主要「工作」被拆分成小塊（佔用相對較少的時間）塊。在塊之間，工作線程檢查（「吃」和清空）隊列，並根據從隊列中提取的數據繼續工作。

如何在Python中實現這個服務器/守護進程？

Answer 1

這是一個帶互聯網套接字的示例代碼，很容易替換爲unix域套接字。它將任何你寫入套接字的東西，作爲一個「命令」傳遞給工作者，只要它已經排隊命令就回應OK。單身工作人員用睡眠模擬冗長的任務（30）。您可以根據需要排列儘可能多的任務，並且每30秒鐘立即接收一次，您的工作人員會從隊列中輸出一條命令。

import Queue, threading, socket 
from time import sleep 

class worker(threading.Thread): 
    def __init__(self,q): 
     super(worker,self).__init__() 
     self.qu = q 

    def run(self): 
     while True: 
      new_task=self.qu.get(True) 
      print new_task 
      i=0 
      while i < 10: 
       print "working ..." 
       sleep(1) 
       i += 1 
       try: 
        another_task=self.qu.get(False) 
        print another_task 
       except Queue.Empty: 
        pass   

task_queue = Queue.Queue() 
w = worker(task_queue) 
w.daemon = True 
w.start() 

sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM) 
sock.bind(('localhost', 4200)) 
sock.listen(1) 
try: 
    while True: 
     conn, addr = sock.accept() 
     data = conn.recv(32) 
     task_queue.put(data) 
     conn.sendall("OK") 
     conn.close() 
except: 
    sock.close()