em-синхронность с использованием http.get и итераторов, вызывающих не может дать в корне ошибка волокна
Очень простой случай, когда я получаю ошибку root Fiber.
require 'em-synchrony'
require 'em-synchrony/em-http'
urls = %w{http://www.google.com http://www.google.com http://www.google.com http://www.google.com http://www.google.com http://www.google.com}
EM.synchrony do
EM::Synchrony::Iterator.new(urls, 2).each(
proc { |url, iter|
EM::HttpRequest.new(url).get
iter.next
}
)
end
Я могу использовать здесь асинхронный, но не HTTP-запрос синхронизации.
1 ответ
Решение
Похоже, что если я собираюсь использовать запрос на получение синхронизации, я должен использовать FiberIterator.
require 'em-synchrony'
require 'em-synchrony/em-http'
require "em-synchrony/fiber_iterator"
urls = %w{http://www.google.com http://www.google.com http://www.google.com http://www.google.com http://www.google.com http://www.google.com}
EM.synchrony do
EM::Synchrony::FiberIterator.new(urls, 2).each(
proc { |url|
EM::HttpRequest.new(url).get
}
)
end