단일 스레드 서버/데몬 (Python) 구현

Question

서버 (데몬)를 개발 중입니다.

서버에는 "작업자 스레드"가 하나 있습니다. 작업자 스레드는 명령 대기열을 실행합니다. 대기열이 비어 있으면 작업자 스레드는 일시 중지됩니다 (메모리의 특정 상태를 보존해야하기 때문에 종료하지 않습니다). 정확히 하나의 상태 복사본을 메모리에 저장하려면 모든 작업자 스레드를 정확하게 실행해야합니다.

클라이언트가 Unix 소켓에 연결하여 명령을 보낼 때이 큐의 끝에 요청이 추가됩니다.

명령이 실행 된 후 작업자 스레드의 명령 대기열에 추가됩니다. 큐에 추가 된 후 서버는 "OK"와 같은 응답을 보냅니다. 서버가 명령을 수신하고 "OK"응답을 보내는 사이에 긴 정지가 없어야합니다. 그러나 대기열에서 명령을 실행하는 데는 약간의 시간이 걸릴 수 있습니다.

작업자 스레드의 주요 "작업"은 작은 (비교적 적은 시간 소요) 청크로 분할됩니다. 청크 사이에서 작업자 스레드는 큐를 검사 ("먹고"비 웁니다)하고 큐에서 추출 된 데이터를 기반으로 작업을 계속합니다.

이 서버/데몬을 Python으로 구현하는 방법은 무엇입니까?

Answer 1

이것은 인터넷 소켓이있는 샘플 코드이며, 유닉스 도메인 소켓으로 쉽게 대체됩니다. 소켓에 쓰는 모든 것을 가져 와서 "명령"으로 worker에 전달하고, 명령을 대기시키는 즉시 확인에 응답합니다. 한 명의 작업자는 sleep (30)이라는 긴 작업을 시뮬레이션합니다. 원하는만큼 많은 작업을 대기열에 넣고 즉시 30 초마다 OK를 받으면 작업자가 대기열에서 명령을 인쇄합니다.

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()