spacepaste

Paste details

reply | raw | toggle line wrapping

  1.  
  2. class StreamWatcher:
  3. def stdout_watcher(self, identifier, stream):
  4. #for line in stream:
  5. for line in iter(stream.readline,b''):
  6. print line
  7. if not stream.closed:
  8. stream.close()
  9. print "-i- Thread Terminating : ", identifier,"\n"
  11. def stderr_watcher(self, identifier, stream):
  12. #for line in stream:
  13. for line in iter(stream.readline,b''):
  14. print (identifier, line)
  15. if not stream.closed:
  16. stream.close()
  17. print "-i- Thread Terminating : ", identifier, "\n"
  23. class something
  24. def somefunc
  25. #did stuff
  26. proc = subprocess.Popen([PathToCurrentPythonInterpreter, toolPath], stderr=subprocess.PIPE, stdout=subprocess.PIPE, env=env, bufsize=1)
  28. #create new stdout and stderr stream listener objects
  29. m=StreamWatcher()
  30. n=StreamWatcher()
  32. #create new threads for each listener, when the listener hears something it prints it to the GUI console log area
  33. Thread(target=m.stdout_watcher, name='stdout-watcher', args=('STDOUT', proc.stdout)).start()
  34. Thread(target=n.stderr_watcher, name='stderr-watcher', args=('STDERR', proc.stderr)).start()
  35.  
Powered by spacepaste. Paste removal.