我有一個功能如下：func keepConnUp(n netAddr, w chan<- io.Writer, err chan error) { addr := fmt.Sprintf("%s:%d", n.Addr, n.Port) for { <-err time.Sleep(reconnectTimer) conn, _ := net.Dial(n.Network, addr) w <- conn }}目標是當我收到來自err chan. 但是，如果我已經在撥號或在某個時間段內，我不想重撥。但是，我可能會收到很多我不想阻止的錯誤。我怎么能那樣做？編輯到目前為止我已經實施的解決方案：func keepConnUp(n netAddr, w chan<- io.Writer, err chan error) { addr := fmt.Sprintf("%s:%d", n.Addr, n.Port) done := make(chan bool) isDialing := false for { select { case <-err: if !isDialing { isDialing = true time.AfterFunc(reconnectTimer, func() { done <- true }) } case <-done: conn, _ := net.Dial(n.Network, addr) w <- conn isDialing = false } }}
3 回答
蝴蝶刀刀
TA貢獻1801條經驗 獲得超8個贊
context.Context自從我從事 Go 工作以來已經有一段時間了，但我嘗試使用and讓它工作sync.Once。我還沒有測試過這個。
func keepConnUp(n netAddr, w chan<- io.Writer, err chan error) {
addr := fmt.Sprintf("%s:%d", n.Addr, n.Port)
done := make(chan bool)
ctx, cancel := context.WithCancel(context.Background())
cancel() // So that ctx.Err() returns non-nil on the first try
once := sync.Once{}
for {
<-err
if ctx.Err() != nil {
once.Do(func() {
conn, _ := net.Dial(n.Network, addr)
w <- conn
})
once = sync.Once{} // Reset once
ctx = context.WithTimeout(reconnectTimer) // Reset context timeout
}
}
}
吃雞游戲
TA貢獻1829條經驗 獲得超7個贊
type Conn struct {
conn net.Conn
dialing bool
mu sync.Mutex
}
func (c Conn) Dial() {
c.mu.Lock()
if c.dialing {
c.mu.Unlock()
return
}
c.dialing = true
c.mu.Unlock()
time.AfterFunc(reconnectTimer, func() {
c.conn, _ := net.Dial(n.Network, addr)
w <- c.conn
c.dialing = false
})
}
現在你可以調用Conn.Dial()一個 goroutine
- 3 回答
- 0 關注
- 144 瀏覽
添加回答
舉報
0/150
提交
取消