实现单线程服务器/守护进程（Python）

Question

我正在开发一个服务器（守护进程）。

服务器有一个“工作线程”。工作线程运行命令队列。当队列为空时，工作线程会暂停（但不会退出，因为它应该在内存中保留某些状态）。要在内存中准确地保存一份状态副本，我需要一直运行一个（不是多个也不是零个）工作线程。

当客户端连接到 Unix 套接字并发送命令时，请求被添加到此队列的末尾。

命令发出后，加入到工作线程的命令队列中。将其添加到队列后，服务器会回复“OK”之类的内容。服务器收到命令和它“OK”回复之间不应该有很长时间的停顿。但是，在队列中运行命令可能需要一些时间。

工作线程的主要“工作”被分成小块（花费相对较少的时间）。在块之间，工作线程检查（“吃”并清空）队列并根据从队列中提取的数据继续工作。

如何在 Python 中实现这个服务器/守护进程？

Answer 1

这是一个带有互联网套接字的示例代码，可以很容易地替换为 unix 域套接字。它将您写入套接字的任何内容，将其作为“命令”传递给工作人员，一旦将命令排入队列，就会响应 OK。单个工作人员使用 sleep(30) 模拟一个冗长的任务。您可以根据需要将任意数量的任务排队，立即收到 OK，并且每 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()