Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- import threading
- import Queue
- import time
- cola = Queue.Queue()
- class worker:
- def __init__(self,cola,ser):
- self.cola = cola
- self.ser = ser
- def read_serial(self,ser):
- while True :
- inp = 'a'
- byte = inp.encode('hex')
- self.cola.put(byte)
- time.sleep(1)
- def go(self):
- th1 = threading.Thread(target=self.read_serial, args=[ser])
- th1.start()
- class worker2:
- def __init__(self,cola,):
- self.cola = cola
- self.ser = ser
- def getrx(self,cola):
- while True:
- rx = self.cola.get()
- print str(rx)
- def go2(self):
- th2 = threading.Thread(target=self.getrx, args=[cola])
- th2.start()
- ser=None
- t = worker(cola,ser)
- t.go()
- t2 = worker2(cola)
- t2.go2()
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement