從子進程複製到父節點的線程

我有一個串口日誌工具，用於處理COM端口的日誌並將它們發送到數據庫。我使用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以某種方式從子進程（它們開始到父進程）複製，所以當我停止線程時，它只會在子進程中停止並繼續從父進程記錄信息。關於這個問題的任何建議？非常感謝你的幫助。

來源

2017-10-04 Anton Belousoff

我在子進程中創建線程，這是錯誤的。 –

我在子進程中創建線程，這是錯誤的。

來源

2017-10-04 12:41:20

從子進程複製到父節點的線程

回答

相關問題