浏览代码

fix dead lock

Darien Raymond 8 年之前
父节点
当前提交
0a15bceb55
共有 1 个文件被更改,包括 2 次插入2 次删除
  1. 2 2
      app/proxyman/mux/mux.go

+ 2 - 2
app/proxyman/mux/mux.go

@@ -42,7 +42,7 @@ func (s *session) closeUplink() {
 	allDone = s.uplinkClosed && s.downlinkClosed
 	allDone = s.uplinkClosed && s.downlinkClosed
 	s.Unlock()
 	s.Unlock()
 	if allDone {
 	if allDone {
-		s.parent.remove(s.id)
+		go s.parent.remove(s.id)
 	}
 	}
 }
 }
 
 
@@ -53,7 +53,7 @@ func (s *session) closeDownlink() {
 	allDone = s.uplinkClosed && s.downlinkClosed
 	allDone = s.uplinkClosed && s.downlinkClosed
 	s.Unlock()
 	s.Unlock()
 	if allDone {
 	if allDone {
-		s.parent.remove(s.id)
+		go s.parent.remove(s.id)
 	}
 	}
 }
 }