JerseyClient异步调用似乎会留下挂起的线程

Question

我正在使用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();

每次创建和销毁其中一个客户端时，都会出现一个新的线程。

有没有安全的方法来销毁这些线程？这是意料之中的行为吗？我做错什么了吗？

Answer 1

在泽西客户端的异步调用中，每当我们在客户端对象上调用关闭（）时，它会破坏异步调用中使用的线程。因此，预计每当执行client.close（）语句时，它会破坏线程，下次将为下一次异步调用创建一个新线程。

现在，考虑到错误场景，关闭客户端对象和关联线程的安全方法之一如下-

    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();
        }
    });