修改脚本为 ClampViewer

GrpcClient.py

@@ -40,6 +40,7 @@ class GrpcStream(threading.Thread):
         cmd=pb.RequestCmd()
         print(" close stream")
         stub.CloseStream(cmd)
+        print(" close stream over")
 
     def loopDataStream(self):
         while self.exit_ == False:
@@ -54,7 +55,7 @@ class GrpcStream(threading.Thread):
                         self.ErrorCallback(str(e))
                     self.clouds_=None
     def run(self):
-        self.threadpool.submit(self.loopDataStream)
+        self.loopDataStream()
         print(" close ")
     def close(self):
         self.exit_=True