Advertisement
Guest User

Untitled

a guest
Sep 11th, 2013
764
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
Python 0.84 KB | None | 0 0
  1. import threading
  2. import Queue
  3. import time
  4.  
  5. cola = Queue.Queue()
  6.  
  7. class worker:
  8.     def __init__(self,cola,ser):
  9.         self.cola = cola
  10.         self.ser = ser
  11.  
  12.     def read_serial(self,ser):
  13.         while True :
  14.             inp = 'a'
  15.             byte = inp.encode('hex')
  16.             self.cola.put(byte)
  17.             time.sleep(1)
  18.  
  19.     def go(self):
  20.         th1 = threading.Thread(target=self.read_serial, args=[ser])
  21.         th1.start()
  22.  
  23. class worker2:
  24.     def __init__(self,cola,):
  25.         self.cola = cola
  26.         self.ser = ser
  27.  
  28.     def getrx(self,cola):
  29.         while True:
  30.             rx = self.cola.get()
  31.             print str(rx)
  32.  
  33.     def go2(self):
  34.         th2 = threading.Thread(target=self.getrx, args=[cola])
  35.         th2.start()
  36.  
  37. ser=None
  38. t = worker(cola,ser)
  39. t.go()
  40. t2 = worker2(cola)
  41. t2.go2()
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement