引入短暂的休眠，减少自旋锁行为 .ehang-io#9

mux.go

@@ -334,7 +334,10 @@ func (s *Mux) Close() (err error) {
 	// while target host close socket without finish steps, conn.Close method maybe blocked
 	// and tcp status change to CLOSE WAIT or TIME WAIT, so we close it in other goroutine
 	_ = s.conn.SetDeadline(time.Now().Add(time.Second * 5))
-	go s.conn.Close()
+	go func() {
+		s.conn.Close()
+		s.bw.Close()
+	}()
 	s.release()
 	return
 }
@@ -361,7 +364,7 @@ func (s *Mux) release() {
 	s.newConnQueue.Stop()
 }
 
-//Get New connId as unique flag
+// Get New connId as unique flag
 func (s *Mux) getId() (id int32) {
 	//Avoid going beyond the scope
 	if (math.MaxInt32 - s.id) < 10000 {
@@ -428,6 +431,10 @@ func (Self *bandwidth) Get() (bw float64) {
 	return
 }
 
+func (Self *bandwidth) Close() error {
+	return Self.fd.Close()
+}
+
 const counterBits = 4
 const counterMask = 1<<counterBits - 1
 

queue.go

@@ -584,6 +584,9 @@ func (c *bufChain) popTail() (unsafe.Pointer, bool) {
 			// dequeue and so popHead doesn't back up
 			// further than necessary.
 			storePoolChainElt(&d2.prev, nil)
+		} else {
+			// 引入短暂的休眠，减少自旋锁行为
+			time.Sleep(100 * time.Microsecond)
 		}
 		d = d2
 	}