关闭chan以防止阻塞

Author: BigeYoung

internal/serial/serial.go

@@ -241,20 +241,24 @@ func GrRxPrase() {
 			}
 
 			// 挂念的变量，还望顺问近祺
-			for _, v := range add {
-				err := SendCmd(variable.Subscribe, v)
-				if err != nil {
-					glog.Errorln("SendCmd error:", err)
+			go func() {
+				for _, v := range add {
+					err := SendCmd(variable.Subscribe, v)
+					if err != nil {
+						glog.Errorln("SendCmd error:", err)
+					}
 				}
-			}
+			}()
 
 			// 无缘的变量，就请随风逝去
-			for _, v := range del {
-				err := SendCmd(variable.Unsubscribe, v)
-				if err != nil {
-					glog.Errorln("SendCmd error:", err)
+			go func() {
+				for _, v := range del {
+					err := SendCmd(variable.Unsubscribe, v)
+					if err != nil {
+						glog.Errorln("SendCmd error:", err)
+					}
 				}
-			}
+			}()
 
 		case <-time.After(200 * time.Millisecond): // 200ms不见
 			if SerialCur.Port == nil || SerialCur.Name == "" {

internal/serial/testport.go

@@ -108,7 +108,9 @@ func testValue(x float64, addr uint32) []byte {
 
 func (tp *testPort) Read(p []byte) (n int, err error) {
 	for len(addresses) == 0 {
-		<-chAddr
+		if _, ok := <-chAddr; !ok {
+			return 0, nil
+		}
 	}
 	data := make([]byte, 0, len(addresses)*40)
 
@@ -190,4 +192,7 @@ func (tp *testPort) GetModemStatusBits() (*serial.ModemStatusBits, error) {
 	return nil, errors.New("not supported")
 }
 
-func (tp *testPort) Close() error { return nil }
+func (tp *testPort) Close() error {
+	close(chAddr)
+	return nil
+}