это вам не руби выучить )

Давайте помечтаем когда уже будет оффлайн конфа

Там вроде про асинхронность прикладной доклад

Или я тебя не очень понял

я, может, его пропустил.Помню, что попадалось что-то со словом async, а сейчас вижу только про async opal
Но это точно не оно

Да ладно, че там прикладного? Там пока мечты и фантазии

кстати, на счет этого. Кто-то может подсказать, что проще всего заюзать в скриптах, когда хочется распараллелить задачи.

Мне недавно надо было поработать с api twilio, вытащить кучу данных для кучи пользователей и обновить базу.
rest апишка у твилио не сильно быстро работает.

Я думал найти какую-то готовую очередь с пулом, чтобы выполнить N задач в X потоков.
Но вот прям "однострочника" не нашел.

Сделал как-то так

pool = Concurrent::FixedThreadPool.new(4)
data = Concurrent::Hash.new

ar_relation.find_each |r|
  pool.post do
    process(r, data) # writes to data[r.id]
  end
end

Но по пулу не понять, что закончилось там все или нет.
Поэтому еще пришлось проверять в цикле, пока data.size не станет == ar_relation.size
А потом уже выходить.

При этом внутри тредов иногда что-то могло упасть и data.size никогда не становился равным ar_relation.size
Есть что-то, что работает параллельно(конкурентно) и умеет отслеживать, выполнились ли все задачи из очереди?

Или надо было просто добавить сюда рубишную очередь? Queue

Но это Kaigi — конференция про развитие языка, не про суровые будни разработчиков

pool = Concurrent::FixedThreadPool.new(4)
data = Concurrent::Hash.new

ar_relation.find_each |r|
  pool.post do
    process(r, data) # writes to data[r.id]
  end
end

Concurrent::Future.execute я вот ето узнал

ты в массив собираешь futures

потом резолвишь

и у тебя массив с данными на выходе

pool = Concurrent::FixedThreadPool.new(4)
data = Concurrent::Hash.new

ar_relation.find_each |r|
  pool.post do
    process(r, data) # writes to data[r.id]
  end
end

если коротко, то надо сходить 10к раз по http и обновить базу (потом). Хотелось ускорить. Желательно в одну-две строки )

вот по етому тутору деляль https://blog.bigbinary.com/2018/06/05/using-concurrent-ruby-in-a-ruby-on-rails-application.html

тоже задача была сходить много раз в хттп

и данные отдать

да, последний кусочек кода выглядит примерно тем, что нужно. спасибо

А давай ты сделаешь нам доклад, и никакая Бразилия для этого теперь не преграда

Там вроде часть уже померджили, так что можно поиграть

почему я и почему Бразилия? )