Как организовать выполнение функций, которые должны постоянно читать данные?

Запустите управляемые циклы чтения с отменой, обработкой EOF и ошибок. Число читателей и очередь результатов должны быть ограничены возможностями источника и потребителей.

Для блокирующего источника цикл должен ожидать данные, а не активно проверять их без паузы. Остановка через context работает, только если чтение поддерживает отмену или ресурс можно безопасно закрыть для разблокировки.

Продумайте владение соединением, порядок сообщений, backpressure и ожидание завершения workers. Не создавайте новую горутину на каждую итерацию без ограничения и не повторяйте постоянную ошибку в горячем цикле.