在像bytes_read,err := conn.Read(tmp)这样的语句中,我希望读取尝试x秒,如果没有读取开始,我希望代码继续前进,检查一些连接,然后再次循环返回并尝试读取。我可以使用select-case并产生两个goroutine,一个尝试读取,另一个尝试超时。但在这里,如果首先发生超时,代码将继续执行,检查条件,并再次生成一个例程,在之前的读取例程仍然有效的情况下尝试从连接中读取。我希望之前的例程在超时发生时终止。
有什么建议可以让我继续下去吗?
发布于 2016-01-20 16:53:14
希望这能对你有所帮助,^_^
for {
// set SetReadDeadline
err := conn.SetReadDeadline(time.Now().Add(5 * time.Second))
if err != nil {
log.Println("SetReadDeadline failed:", err)
// do something else, for example create new conn
return
}
recvBuf := make([]byte, 1024)
n, err = conn.Read(recvBuf[:]) // recv data
if err != nil {
if netErr, ok := err.(net.Error); ok && netErr.Timeout() {
log.Println("read timeout:", err)
// time out
} else {
log.Println("read error:", err)
// some error else, do something else, for example create new conn
}
}
}https://stackoverflow.com/questions/34892507
复制相似问题