spacepaste

Paste details

reply | raw | toggle line wrapping

  1.  
  2. #####################################################################
  3. # redirectText.py
  4. #
  5. # Created by Mike Driscoll
  6. #
  7. # Contact: mike@pythonlibrary.org
  8. # Website: http://www.blog.pythonlibrary.org
  9. #
  10. # Tested on Windows XP, Python 2.5.2, wxPython 2.8.9.1 (msw-unicode)
  11. #####################################################################
  13. import sys
  14. import os
  15. import wx
  16. import threading
  17. import time
  18. #import SomeModule1
  20. class RedirectText(object):
  21. def __init__(self,aWxTextCtrl):
  22. self.out=aWxTextCtrl
  24. def write(self,string):
  25. wx.CallAfter(self.out.WriteText, string)
  28. from subprocess import Popen, PIPE
  29. from threading import Thread
  30. from threading import Lock
  31. from Queue import Queue, Empty
  33. io_q = Queue()
  34. processList=[]
  35. lock = Lock()
  37. class StreamWatcher:
  38. def stdout_watcher(self, identifier, stream):
  39. #for line in stream:
  40. for line in iter(stream.readline,b''):
  41. print line
  42. if not stream.closed:
  43. stream.close()
  44. print "-i- Thread Terminating : ", identifier,"\n"
  46. def stderr_watcher(self, identifier, stream):
  47. #for line in stream:
  48. for line in iter(stream.readline,b''):
  49. print (identifier, line)
  50. if not stream.closed:
  51. stream.close()
  52. print "-i- Thread Terminating : ", identifier, "\n"
  54. import sys
  55. import subprocess
  56. import random
  57. import time
  58. import threading
  59. import Queue
  61. class AsynchronousFileReader(threading.Thread):
  62. '''
  63. Helper class to implement asynchronous reading of a file
  64. in a separate thread. Pushes read lines on a queue to
  65. be consumed in another thread.
  66. '''
  68. def __init__(self, fd, queue):
  69. assert isinstance(queue, Queue.Queue)
  70. assert callable(fd.readline)
  71. threading.Thread.__init__(self)
  72. self._fd = fd
  73. self._queue = queue
  75. def run(self):
  76. '''The body of the tread: read lines and put them on the queue.'''
  77. for line in iter(self._fd.readline, ''):
  78. self._queue.put(line)
  80. def eof(self):
  81. '''Check whether there is no more content to expect.'''
  83. isDead = not self.is_alive() and self._queue.empty()
  84. if isDead:
  85. self.join()
  86. self._fd.close()
  89. class MyGUI(wx.Frame):
  91. def __init__(self):
  92. wx.Frame.__init__(self, None, wx.ID_ANY, "wxPython Redirect Tutorial")
  94. # Add a panel so it looks the correct on all platforms
  95. panel = wx.Panel(self, wx.ID_ANY)
  96. log = wx.TextCtrl(panel, wx.ID_ANY, size=(300,100),
  97. style = wx.TE_MULTILINE|wx.TE_READONLY|wx.HSCROLL)
  98. btn = wx.Button(panel, wx.ID_ANY, 'Push me!')
  99. self.Bind(wx.EVT_BUTTON, self.onButton, btn)
  101. # Add widgets to a sizer
  102. sizer = wx.BoxSizer(wx.VERTICAL)
  103. sizer.Add(log, 1, wx.ALL|wx.EXPAND, 5)
  104. sizer.Add(btn, 0, wx.ALL|wx.CENTER, 5)
  105. panel.SetSizer(sizer)
  107. # redirect text here
  108. redir=RedirectText(log)
  109. sys.stdout=redir
  110. sys.stderr=redir
  111. self.stdout_queue = Queue.Queue()
  112. self.stderr_queue = Queue.Queue()
  114. def onButton(self, event):
  115. print ("-i- this is printed from GUI module itself")
  117. #SomeModule1.printSomething()
  120. PathToCurrentPythonInterpreter = os.path.abspath(os.path.join(sys.prefix, "python.exe"))
  121. modPath = os.path.abspath( os.path.join(os.path.abspath(os.path.dirname(__file__)),'SomeModule1.py') )
  122. print PathToCurrentPythonInterpreter
  123. print modPath
  124. proc = Popen([PathToCurrentPythonInterpreter, modPath], stdout=PIPE, stderr=PIPE, bufsize=1)
  126. #m=StreamWatcher()
  127. #n=StreamWatcher()
  129. #Thread(target=m.stdout_watcher, name='stdout-watcher', args=('STDOUT', proc.stdout, self.stdout_queue)).start()
  130. #Thread(target=n.stderr_watcher, name='stderr-watcher', args=('STDERR', proc.stderr, self.stderr_queue)).start()
  131. Thread(target=self.printerThread, name='stderr-watcher').start()
  132. stdout_reader = AsynchronousFileReader(proc.stdout, self.stdout_queue).start()
  133. stderr_reader = AsynchronousFileReader(proc.stderr, self.stderr_queue).start()
  136. #self.processList.append(proc)
  137. def printerThread(self):
  138. print "printer!"
  139. # Check the queues if we received some output (until there is nothing more to get).
  140. while True:
  141. # Show what we received from standard output.
  142. while not self.stdout_queue.empty():
  143. line = self.stdout_queue.get()
  144. print 'Received line on standard output: ' + repr(line)
  146. # Show what we received from standard error.
  147. while not self.stderr_queue.empty():
  148. line = self.stderr_queue.get()
  149. print 'Received line on standard error: ' + repr(line)
  151. # Sleep a bit before asking the readers again.
  152. time.sleep(.1)
  154. # Run the program
  155. if __name__ == "__main__":
  156. app = wx.PySimpleApp()
  157. frame = MyGUI().Show()
  158. app.MainLoop()
  159.  
Powered by spacepaste. Paste removal.