должен вернуть сообщение из одной из очередей (указывается из какой конкретно пользователем). Пользователь в запросе может указать таймаут, который будем ждать в случае если очередь пуста(мало ли сообщение в ней всё-таки появится и его можно будет вернуть пользователю). В случае если несколько клиентов ждут ответ с таймаутом, получить его первым должен тот, кто раньше всех запрос отправил. Вопрос: как реализовать последнее? Конкретнее - как уследить за тем, кто из клиентов отправил запрос раньше и каким образом именно тому кто ждёт дольше отдать сообщение?
можете подсмотреть вот куда: сделать LRU cache для запросов Если первый забрал запрос — отдать ему, остальных абортнуть можете посомтреть из реализации stampede middleware для chi-router, там поведение такое — все запросы на какой-то ресурс паркуем в кеш и если ответ для первого — всем отдать этот ответ, в вашем случае не отдать ответ, а абортнуть https://github.com/go-chi/stampede/blob/master/stampede.go#L65
Обсуждают сегодня