H/W4

noblocking_turtle_shell.py

@@ -1,18 +1,29 @@
 import cmd
 import threading
 
-from queue import Queue
+from queue import Empty, Queue
 
 from equipment.turtle_device import TurtleDevice
 
 
 class TurtleDeviceThread(threading.Thread):
-    # TODO(Homework 4)
     def __init__(self):
         super().__init__()
         self.device = TurtleDevice()
         self.queue = Queue()
         
+    def run(self):
+        while True:
+            try:
+                item = self.queue.get()
+            except self.queue.Empty:
+                continue
+            else:
+                if (item == 'exit'):
+                    break
+                self.device.execute(item[0], item[1:])
+                self.queue.task_done()
+    
 
 class NoBlockingTurtleShell(cmd.Cmd):
     intro = 'Welcome to the turtle shell.   Type help or ? to list commands.\n'
@@ -20,16 +31,16 @@ class NoBlockingTurtleShell(cmd.Cmd):
     file = None
 
     def __init__(self, turtle_thread: TurtleDeviceThread):
-        pass  # TODO(Homework 4)
+        self.turtle_thread = TurtleDeviceThread()
 
     def do_execute(self, arg):
-        pass  # TODO(Homework 4)
+        self.turtle_thread.queue.put(arg)
 
     def do_exit(self, arg):
-        pass  # TODO(Homework 4)
+        self.turtle_thread.queue.put('exit')
 
 
 if __name__ == '__main__':
     turtle_thread = TurtleDeviceThread()
-    # TODO(Homework 4: Correct start thread)
+    turtle_thread.start()
     NoBlockingTurtleShell(turtle_thread).cmdloop()