Ну в этом как мне кажется и фишка го, создал пул воркеров, которые ждут входящих данных, а в другом месте получаешь данные и забрасываешь по каналам. Главное правильно синхронизацию и завершение рутин сделать, чтобы они не потекли и нарушений целостности данных не было и красота. Разделил задачу на части, ускорив намного обработку данных