Отправка нескольких асинхронных запросов на клиенте Netty

сначала позвольте мне объяснить контекст:

Мне нужно создать клиент, который будет отправлять множество HTTP-запросов на загрузку изображений. Эти запросы должны быть асинхронными, потому что, как только изображение будет готово, оно будет добавлено в очередь, а затем напечатано на экране. Поскольку изображения могут быть большими, а ответы разбиты на фрагменты, мой обработчик должен агрегировать их в буфер.

Итак, я следую кодам примеров Netty ( Пример ложки HTTP).

В настоящее время у меня есть три статических карты для хранения для каждого канала идентификатора канала и буфера/фрагмента логического значения/моего конечного объекта.

private static final ConcurrentHashMap BUFFER_MAP = new ConcurrentHashMap();
private static final ConcurrentHashMap PACK_MAP = new ConcurrentHashMap();
private static final ConcurrentHashMap CHUNKS_MAP = new ConcurrentHashMap();

После этого я создаю свой загрузочный клиент и счетчик для обратного отсчета количества ожидающих запросов. Окончательная очередь и счетчик передаются моему обработчику, когда изображение ответа завершено.

    final ClientBootstrap bootstrap = new ClientBootstrap(
            new NioClientSocketChannelFactory(
            Executors.newCachedThreadPool(),
            Executors.newCachedThreadPool()));
    bootstrap.setOption("keepAlive", true);
    bootstrap.setOption("tcpNoDelay", true);
    bootstrap.setOption("reuseAddress", true);
    bootstrap.setOption("connectTimeoutMillis", 30000);


    final CountDownLatch latch = new CountDownLatch(downloadList.size()) {

        @Override
        public void countDown() {
            super.countDown();
            if (getCount() <= 0) {
                try {
                    queue.put(END_OF_QUEUE);
                    bootstrap.releaseExternalResources();
                } catch (InterruptedException ex) {
                    LOGGER.log(Level.WARNING, ex.getMessage(), ex);
                }
            }
        }
    };
    bootstrap.getPipeline().addLast("codec", new HttpClientCodec());
    bootstrap.getPipeline().addLast("handler", new TileClientHandler(queue, latch));

После этого я создаю канал для загрузки каждого изображения, и когда канал подключен, запрос будет создан и отправлен. Хост и порт уже были извлечены ранее.

for (final ImagePack pack : downloadList) {

        final ChannelFuture future = bootstrap.connect(new InetSocketAddress(host, port));

        future.addListener(new ChannelFutureListener() {

            public void operationComplete(ChannelFuture cf) throws Exception {

                final Channel channel = future.getChannel();

                PACK_MAP.put(channel.getId(), pack);

                final HttpRequest request = new DefaultHttpRequest(HttpVersion.HTTP_1_1, HttpMethod.GET, pack.url);
                request.setHeader(HttpHeaders.Names.HOST, host);
                request.setHeader(HttpHeaders.Names.CONNECTION, HttpHeaders.Values.CLOSE);
                request.setHeader(HttpHeaders.Names.ACCEPT_ENCODING, HttpHeaders.Values.BYTES);

                if (channel.isWritable()) {
                    channel.write(request);
                }
            }
        });
    }

Теперь это мой ChannelHandler, который является внутренним классом, расширяющим SimpleChannelUpstreamHandler. Когда канал подключен, создается новая запись в BUFFER_MAPи в CHUNKS_MAP.BUFFER_MAPсодержит все буферы изображений, используемые обработчиком для агрегирования фрагментов изображений из каналов, а CHUNKS_MAPсодержит логическое значение ответа на фрагменты. Когда ответ завершен, изображение InputSteamдобавляется в очередь, защелка отсчитывается и канал закрывается.

private class TileClientHandler extends SimpleChannelUpstreamHandler {

    private CancellableQueue