fork download
  1. import threading
  2. import Queue
  3. import time
  4. from array import array
  5. from sys import byteorder
  6. import pyaudio
  7.  
  8. class Audio(threading.Thread):
  9.  
  10. base_data = {
  11.  
  12. 'chunk' : 0.0,
  13. 'format' : 0.0,
  14. 'channels' : 0.0,
  15. 'rate' : 0.0,
  16. 'length' : 0.0,
  17. }
  18.  
  19. p = None
  20. stream = None
  21. THRESHOLD = 500 # set the constant
  22.  
  23. def __init__(self, q):
  24.  
  25. threading.Thread.__init__(self)
  26. self.p = pyaudio.PyAudio()
  27.  
  28. def run(self):
  29.  
  30. self.stream = self.p.open(format= pyaudio.paInt16,
  31. channels= 2,
  32. rate=44100,
  33. input=True,
  34. frames_per_buffer=1024)
  35.  
  36. while True:
  37.  
  38. for i in range(0, int(44100 / 1024 * 10)):
  39.  
  40. print "I'm working"
  41.  
  42. time.sleep(10)
  43.  
  44. def process(self, q):
  45. # this should come in after every 10 seconds
  46. print "I am processing"
  47.  
  48. time.sleep(10)
  49.  
  50. if __name__ == '__main__':
  51. shared_queue = Queue.Queue()
  52. worker = Audio(shared_queue)
  53. worker.start()
  54. worker.process(shared_queue)
  55.  
Runtime error #stdin #stdout #stderr 0.1s 8880KB
stdin
Standard input is empty
stdout
Standard output is empty
stderr
Traceback (most recent call last):
  File "prog.py", line 6, in <module>
    import pyaudio
ImportError: No module named pyaudio