Поведение странной нити

Question

Я относительно новичок в python, но не для многопоточного программного обеспечения, поэтому я не могу объяснить конкретное поведение, которое я вижу. Моя программа довольно проста: я отслеживаю вывод команды linux «iostat» и что-то делаю в некоторой ситуации. Мой код выглядит следующим образом:

class SysMonitor(threading.Thread): 

def __init__(self): 
    threading.Thread.__init__(self) 
    self.isStopping = False 
    self.ioprocess = [] 

def run(self): 
    self.ioprocess = subprocess.Popen(['/usr/bin/iostat', '-p', 'sda', '60'], stdout=subprocess.PIPE) 
    p = self.ioprocess 
    i = 0 

    # Discard first output 
    while (i < 11): 
     p.stdout.readline() 
     i = i + 1 

    # Now keep on waiting on new output from iostat and then process it when it comes in 
    while (not self.isStopping): 
     select.select([p.stdout], [], []) 

     # Don't process the last output if we are stopping 
     if (self.isStopping): 
      print 'Quitting, discarding last buffer:' + str(self.isStopping) 
      continue 

     # do some p.stdout.readline() and process the data 

def stop(self): 
    self.isStopping = True 
    self.ioprocess.terminate() 

То, что я не понимаю, что когда я вызываю функцию «стоп», программа иногда выходит из строя, так как выбор свободен, потому что EOF записывается в буфере стандартного вывода, но isStopping по-прежнему ложно. Как это может произойти?

Answer 1

Если stop() вызывается вне темы, это может привести к случайным проблемам. Потому что когда вы назовете stop(), нить может быть в любом случае, в печати или в выборе и т. Д.

Просто переместите ваш terminate() в конце метода run(). Затем установка isStopping в True будет корректно покидать цикл, а затем завершить процесс.

Если вы хотите, чтобы ждать его, вы можете присоединиться к нитке:

def stop(self): 
    self.isStopping = True 
    self.join() 

Answer 2

Опираясь на tito's answer, и относительно вашего комментария, вы можете использовать тайм-аут в select.select:

while (not self.isStopping): 
     ready, _, _ = select.select([p.stdout], [], [], 5.0) 

     # Don't process the last output if we are stopping 
     if (self.isStopping): 
      print 'Quitting, discarding last buffer:' + str(self.isStopping) 
      continue 
     if ready: 
      # do some p.stdout.readline() and process the data 

    self.ioprocess.terminate() 

Выше, время ожидания составляет 5,0 секунд. Я полагаю, что это достаточно долго, чтобы не забивать систему и достаточно короткое для разумного завершения. Измените свой вкус.

Answer 3

Если целью является завершение потока при завершении приложения, установите поток как демон.