Tengo un dispositivo que se comunica con mi Go Websocket constantemente. Los mensajes que le envío siempre tienen una respuesta, pero a veces el dispositivo toma demasiado tiempo en responder, por lo que hago intentos con un tiempo x como límite. Ahora, a pesar de ello el dispositivo puede o no responderme luego del tiempo e intentos límite, esto provoca errores del tipo panic (panic: send on closed channel).
Lo que necesito es poder evitar los panics y usar de forma eficiente los recursos (cerrando los channels y dejando sin referencias a las goroutines para que puedan liberar su memoria luego de que termine la función en la que se encuentran).
Este código genera panics si el dispositivo me responde luego de 3 intentos de 5 segundos de espera cada uno.
resp := make(chan Response, 1)
aux := make(chan int, 1)
var ok Response
// Hilo, que notifica por el canal "aux" la respuesta del dispositivo (ok)
go func() {
select {
case ok = <-resp:
aux <- 4
}
}()
var i int
for i = 1; i < 4; i++ {
fmt.Println("Inicia intento n ", i)
// Hilo, que envia comando y escucha la respuesta del dispositivo
go func() {
resp <- ChangeAvailability(data)
}()
// Hilo, que detiene re-intentos al recibir respuesta del dispositivo
go func() {
i = <-aux
}()
// Re-intentos cada x segundos
<-time.After(15 * time.Second)
}
// Evitando deadlock
close(resp)
close(aux)
// Respuestas hacia el cliente
ManejandoRespuestaCliente(i, ok)
Con recover puedo manejar el panic, pero sigue sin ser muy eficiente en el uso de recursos.
No encuentro la lógica que debo implementar para que responda o no el dispositivo luego de x tiempo, pueda cerrar los channels para liberar memoria sin generar panics.