AsyncHttpClient создает слишком много потоков AsyncHttpClient-timer

Я использую AsyncHttpClient 2.3.0 и конфигурацию по умолчанию.

Я заметил, что AHC создал два типа потоков (из дампа потока):

1) 

AsyncHttpClient-timer-478-1" - Thread t@30390    java.lang.Thread.State: TIMED_WAITING
        at java.lang.Thread.$$YJP$$sleep(Native Method)
        at java.lang.Thread.sleep(Thread.java)
        at io.netty.util.HashedWheelTimer$Worker.waitForNextTick(HashedWheelTimer.java:560)
        at io.netty.util.HashedWheelTimer$Worker.run(HashedWheelTimer.java:459)
        at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
        at java.lang.Thread.run(Thread.java:748)

2) 

AsyncHttpClient-3-4" - Thread t@20320    java.lang.Thread.State: RUNNABLE
        at sun.nio.ch.EPollArrayWrapper.$$YJP$$epollWait(Native Method)
        at sun.nio.ch.EPollArrayWrapper.epollWait(EPollArrayWrapper.java)
        at sun.nio.ch.EPollArrayWrapper.poll(EPollArrayWrapper.java:269)
        at sun.nio.ch.EPollSelectorImpl.doSelect(EPollSelectorImpl.java:93)
        at sun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:86)
        - locked <16163575> (a io.netty.channel.nio.SelectedSelectionKeySet)
        - locked <49280039> (a java.util.Collections$UnmodifiableSet)
        - locked <2decd496> (a sun.nio.ch.EPollSelectorImpl)
        at sun.nio.ch.SelectorImpl.select(SelectorImpl.java:97)
        at io.netty.channel.nio.SelectedSelectionKeySetSelector.select(SelectedSelectionKeySetSelector.java:62)
        at io.netty.channel.nio.NioEventLoop.select(NioEventLoop.java:753)
        at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:409)
        at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:886)
        at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
        at java.lang.Thread.run(Thread.java:748)

Я ожидал, что AsyncHttpClient использует несколько потоков под капотом. Но после нескольких дней работы AsyncHttpClient создает ~500 потоков AsyncHttpClient-timer-xxx-x и несколько потоков AsyncHttpClient-x-x. Вызывается не очень интенсивно, наверное тоже ~500 раз за этот период. Используется только executeRequest (выполнить запрос и получить возвращенное будущее) https://static.javadoc.io/org.asynchttpclient/async-http-client/2.3.0/org/asynchttpclient/AsyncHttpClient.html#executeRequest-org.asynchttpclient.Request-org.asynchttpclient.AsyncHandler-:

<T> ListenableFuture<T> executeRequest(Request request, AsyncHandler<T> handler);

Я видел страницу о конфигурации пула соединений (https://github.com/AsyncHttpClient/async-http-client/wiki/Connection-pooling), но ничего о конфигурации пула потоков.

В чем разница между обоими типами потоков и что может привести к созданию большого количества потоков? Есть ли какая-либо конфигурация, которую я должен применить?


java multithreading netty asynchttpclient
person Mike Mike    schedule 08.08.2019    source источник

Ответы (1)


arrow_upward
0
arrow_downward

AHC имеет два типа резьбы:

  1. Для операций ввода/вывода. На вашем экране это потоки AsyncHttpClient-x-x. AHC создает 2*core_number из них.
  2. Для тайм-аутов. На вашем экране это поток AsyncHttpClient-timer-1-1. Должен быть только один.

Любое другое число означает, что вы создаете несколько клиентов.

Источник: проблема на GitHub https://github.com/AsyncHttpClient/async-http-client/issues/1658

person Mike Mike    schedule 08.08.2019