자식 프로세스에서 부모 프로세스로 복사 된 스레드

Question

COM 포트에서 로그를 처리하여 DB로 보내는 직렬 로깅 유틸리티가 있습니다. 프로토콜 팩토리와 함께 pyserial ReaderThread를 사용하고 있습니다.

class SerialLogging(Process): 
    def __init__(self, cpath, q): 
     Process.__init__(self) 
     self.__queue = q 
     config = configparser.ConfigParser() 
     config.optionxform = str 
     config.read(cpath) 
     self.__configs = list() 
     for section in config.sections(): 
      self.__configs.append(dict(config.items(section))) 
     if len(self.__configs) <= 0: 
      return 1 

     self.__serials = list() 
     for config in self.__configs: 
      if config['status'] == 'on': 
       self.__serials.append({'thread': threaded.ReaderThread(serial.Serial(config['port'], baudrate=config['baudrate'], timeout=1), lambda config=config: PrintLines(config['device'])), 'port': config['port'], 'device': config['device'], 'baudrate' : config['baudrate']}) 

     for ser in self.__serials: 
      try: 
       ser['thread'].start() 
       ser['status'] = 'on' 
      except: 
       ser['status'] = 'off' 


    def run(self): 
     while True: 
      try: 
       message = self.__queue.get_nowait() 
       self.__queue.task_done() 
      except queue.Empty: 
       continue 
      if 'close' in message: 
       self.__disable(message.split(' ')[1]) 
       self.__queue.put('ok') 
      elif 'run' in message: 
       self.__enable(message.split(' ')[1]) 
       self.__queue.put('ok') 
      elif 'list' in message: 
       self.__queue.put(self.__list()) 
     return  

    def __disable(self, port): 
     for serial in self.__serials: 
      if serial['port'] == port and serial['status'] == 'on': 
       serial['thread'].close() 
       serial['status'] = 'off'  

    def __enable(self, port): 
     for ser in self.__serials: 
      if ser['port'] == port and ser['status'] == 'off': 
       ser['thread'] = threaded.ReaderThread(serial.Serial(ser['port'], baudrate=ser['baudrate'], timeout=1), lambda ser=ser: PrintLines(ser['device'])) 
       ser['thread'].start() 
       ser['status'] = 'on' 

    def __list(self): 
     return ['%s=%s %s' % (serial['port'], serial['device'], serial['status']) for serial in self.__serials] 

SerialLogging 클래스는 별도의 프로세스로 인스턴스화됩니다. 문제는 ReaderThreads가 부모 프로세스에서 시작된 자식 프로세스에서 어떻게 든 복사되므로 스레드를 중지 할 때 자식 프로세스에서만 중지되고 부모 프로세스의 정보를 계속 기록한다는 것입니다. 이 문제에 대한 제안 사항이 있으십니까? 당신의 도움에 정말로 감사 할 것입니다.

Answer 1

자식 프로세스에서 스레드를 생성하고 있는데 잘못되었습니다.