В этом задании вам предстоит поработать с Concurrency
в Ruby
.
Задание задаёт конкретную планку по времени, в которую вам нужно уложиться.
В попытках добраться до заданной планки вам придётся разобраться c Concurrency
.
- install ruby из .ruby-version
- bundle install
В комплект задания входит сервер, на Sinatra
+ Falcon
.
Его надо запускать командой bundle exec falcon serve -c config.ru --threaded
Именно в режиме threaded
. (И именно ту версию что в Gemfile, в последующих что-то сломалось на момент когда я их пробовал)
Сервер предоставляет три эндпоинта: a
, b
, c
.
a
отвечает за1 секунду
b
отвечает за2 секунды
c
отвечает за1 секунду
Эндпоинты можно вызывать несколько раз одновременно, но в них есть "защита от перегрева".
Если эндпоинт вызывается слишком интенсивно, то запрос, вызвавший перегрев, засыпает на длительное время, чтобы дать серверу охладится. После завершения ожидания клиент получает корректный ответ.
Ограничения на перегрев такие:
a
- одновременно может выполняться3 экземпляра
b
- одновременно может выполняться2 экземпляра
c
- одновременно может выполняться1 экземпляр
В комплект задания входит и клиент, который корректно решает поставленную задачу. Он делает несколько запросов к серверу, как-то их комбинирует и выводит результат.
Проблема в том, что референсное решение отработывает примерно 19,5 секунд
, а в задании требуется уложиться в < 7 секунд
.
-
Use puts for debugging and understanding of what's going on in your async system
-
Начните с того, чтобы нарисовать схему взаимосвязей из референсного решения, и с её помощью найти схему организации вычислительного процесса, которая сможет уложиться в заданные рамки (с учётом защиты от перегрева).
-
В процессе решения вы скорее всего столкнётесь с ситуацией, что понятно, что нужно сделать, но непонятно как: например, выполнить несколько асинхронных задач параллельно и дождаться завершения всех из них. В таких случаях попытайтесь нагуглить типовые решения подобных задач. В процессе поиска вы сможете найти общие шаблоны решения подобных задач, способы их решения в разных языках и библиотеках. В итоге вы поймёте как это сделать в
Ruby
. -
Я рекомендую использовать
socketry/async
для решения этого задания. Почитайте документацию. Обратите внимание наsemaphore
,barrier
. Если хотите, вы можете использовать что-то ещё, напримерThread
. -
В референсном решении для запросов к серверу используется
Faraday
, можно использовать другие клиенты на ваш выбор.
Результатом является PR
в этот репозиторий, в котором client.rb
делает все те же запросы к серверу, получает корректный результат, но выполняется строго меньше 7 секунд
.