Как параллельно отправить N get запросов и дождаться от всех ответа?

Question

[kidar2]

К стороннему сервису надо сделать кучу запросов, а последовательно это довольно долго.
Кроме отдельных потоков можно как-то ещё? В идеале было бы как js - асинхронно.

Comments

[razer89]

а чем потоки не устраивают?

Answer 1

[kidar2]

Вот это вроде похоже на правду:

urls.parallelStream().forEach(u ->
		{
			LOG.debug("Page: " + u + usersResponse.pages.total_pages);
			try
			{
				String r = <Send getRequest>
			}
			catch (Exception e)
			{
				LOG.error(e);
			}
		});

Comments

[⚡ Kotobotov ⚡]

сам запрос нужно ассинхроно отправлять и потом предоставить композитный ответ.
такого простого функционала в java несуществует, есть сторонние фреймворки на основе nio, например akka, также в scala встроен функционал простой отправки ассинхронных запросов и получения и последующей обработки фьючерсов.
там это на основе Promises делается композитный ответ через flatmap, можно собрать.

[kidar2]

Так вроде этот вариант работает

[Алексей Черемисин]

Ну, во первых это в java8, а во вторых я бы сделал так (не компилировал):

ForkJoinPool forkJoinPool = new ForkJoinPool(8);
forkJoinPool.submit(() ->
urls.parallelStream().forEach(u ->
    {
      LOG.debug("Page: " + u + usersResponse.pages.total_pages);
      try
      {
        String r = <Send getRequest>
      }
      catch (Exception e)
      {
        LOG.error(e);
      }
    })
).get();

[kidar2]

Это чтобы ограничить число потоков? Круто, спс

Answer 2

[aol-nnov]

RxJava + OkHttp? )