Асинхронные вызовы JerseyClient, кажется, оставляют зависшие потоки

Я использую jersey-client-3.0-SNAPSHOT.

Я делаю что-то вроде:

 final Client client = createClient();

...

    Builder builder = target.request();
    for (final Entry<String, String> entry : getHeaders().entrySet()) {
        builder = builder.header(entry.getKey(), entry.getValue());
    }
    final Builder finalBuilder = builder;
    executor.submit(() -> {
        final Entity<?> entity = createPostEntity();
        futureResponse = finalBuilder.async().post(entity);
        try {
            response = futureResponse.get(TIMEOUT_MILLIS, TimeUnit.MILLISECONDS);
            consumeResponse(response);
        } catch (ExecutionException | TimeoutException | InterruptedException | IOException e) {
            errorConsumer.accept(e);
        }
    });

    if (futureResponse != null) {
        try {
            futureResponse.cancel(true);
        } catch (final Exception e) {
            //does nothing, now we try keep closing resources
        }
    }
    if (response != null) {
        try {
            response.close();
        } catch (final Exception e) {
            //does nothing, now we try keep closing resources
        }
    }

... // ждем ответов и читаем или что-то еще

client.close();

И новый поток продолжает появляться каждый раз, когда создается и уничтожается один из этих клиентов.

Есть ли безопасный способ уничтожить эти потоки? Это ожидаемое поведение? Я делаю что-то не так?


java multithreading jersey-client
person eduyayo    schedule 02.06.2017    source источник

Ответы (1)


arrow_upward
2
arrow_downward

При вызове asynchronous в Jersey client всякий раз, когда мы вызываем close() для объекта client, он уничтожает thread, используемый в вызове async. Таким образом, ожидается, что всякий раз, когда будет выполняться оператор client.close(), он уничтожит поток, и в следующий раз будет создан новый поток для следующего вызова async.

Теперь один из безопасных способов закрыть объект client и связанный с ним поток с учетом сценария ошибки приведен ниже:

    Client client = ClientBuilder.newClient();

    WebTarget webTarget = client.target(SERVER_URL).path(API_PATH);

    Invocation.Builder invocationBuilder = webTarget.request(MediaType.APPLICATION_JSON);
    // set headers and other stuff

    AsyncInvoker asyncInvoker = invocationBuilder.async();

    asyncInvoker.get(new InvocationCallback<Response>() {

        @Override
        public void completed(Response response) {
            if (response.getStatusInfo().equals(Status.OK)) {
               // parse the response in success scenario
            } else {
               // parse the response if error response is received from server
            }
            client.close();
        }

        @Override
        public void failed(Throwable throwable) {
            System.out.println("An error occurred while calling API");
            throwable.printStackTrace();
            client.close();
        }
    });
person Vikas Sachdeva    schedule 10.06.2017