实现单线程服务器/守护进程（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()