如何在我的线程中断时立即中断RestTemplate调用？

Question

我需要使一个库，我将有同步和异步的特点。

• executesynchronous()-等待得到结果，返回结果。
• executeAsynchronous()-立即返回一个将来值，如果需要，该将来值可以在其他事情完成后处理。

my Library的核心逻辑

public interface Client {

    // for synchronous
    public DataResponse executeSynchronous(DataKey key);

    // for asynchronous
    public Future<DataResponse> executeAsynchronous(DataKey key);
}

public class DataClient implements Client {

    private RestTemplate restTemplate = new RestTemplate();
    private ExecutorService executor = Executors.newFixedThreadPool(10);

    // for synchronous call
    @Override
    public DataResponse executeSynchronous(DataKey key) {
        DataResponse dataResponse = null;
        Future<DataResponse> future = null;

        try {
            future = executeAsynchronous(key);
            dataResponse = future.get(key.getTimeout(), TimeUnit.MILLISECONDS);
        } catch (TimeoutException ex) {
            PotoLogging.logErrors(ex, DataErrorEnum.TIMEOUT_ON_CLIENT, key);
            dataResponse = new DataResponse(null, DataErrorEnum.TIMEOUT_ON_CLIENT, DataStatusEnum.ERROR);
            // does this looks right?
            future.cancel(true); // terminating tasks that have timed out
        } catch (Exception ex) {
            PotoLogging.logErrors(ex, DataErrorEnum.CLIENT_ERROR, key);
            dataResponse = new DataResponse(null, DataErrorEnum.CLIENT_ERROR, DataStatusEnum.ERROR);
        }

        return dataResponse;
    }

    //for asynchronous call
    @Override
    public Future<DataResponse> executeAsynchronous(DataKey key) {
        Future<DataResponse> future = null;

        try {
            Task task = new Task(key, restTemplate);
            future = executor.submit(task); 
        } catch (Exception ex) {
            PotoLogging.logErrors(ex, DataErrorEnum.CLIENT_ERROR, key);
        }

        return future;
    }
}

将执行实际任务的简单类：

public class Task implements Callable<DataResponse> {

    private DataKey key;
    private RestTemplate restTemplate;

    public Task(DataKey key, RestTemplate restTemplate) {
        this.key = key;
        this.restTemplate = restTemplate;
    }

    @Override
    public DataResponse call() {
        DataResponse dataResponse = null;
        String response = null;

        try {
            String url = createURL();
            response = restTemplate.getForObject(url, String.class);

            // it is a successful response
            dataResponse = new DataResponse(response, DataErrorEnum.NONE, DataStatusEnum.SUCCESS);
        } catch (RestClientException ex) {
            PotoLogging.logErrors(ex, DataErrorEnum.SERVER_DOWN, key);
            dataResponse = new DataResponse(null, DataErrorEnum.SERVER_DOWN, DataStatusEnum.ERROR);
        } catch (Exception ex) {
            PotoLogging.logErrors(ex, DataErrorEnum.CLIENT_ERROR, key);
            dataResponse = new DataResponse(null, DataErrorEnum.CLIENT_ERROR, DataStatusEnum.ERROR);
        }

        return dataResponse;
    }

    // create a URL by using key object
    private String createURL() {
        String url = somecode;
        return url;
    }
}

当我开始处理此解决方案时，我并没有终止超时的任务。我向客户机报告超时，但任务继续在线程池中运行（可能会长时间占用我有限的10个线程中的一个）。所以我在网上做了一些研究，我发现我可以通过使用取消未来来取消超时的任务，如下所示-

future.cancel(true);

但是，如果我像上面的解决方案中所示那样执行这样的操作，那么线程一旦中断，我是否需要关闭任何其他资源，如resttemplate？如果是，那我该怎么做？另外，我们可以中断resttemplate调用吗？因为我试图在任务超时后立即在我的未来上调用cancel，但我想我的线程没有被打断。

Answer 1

似乎无法中断或取消对RESTTemplate的调用。即使使用了使用回调的“kludge”，RESTTemplate也可能在内部锁定资源，在调用回调之前等待响应。

当底层套接字可以访问时，可以通过从另一个线程关闭套接字来中止网络I/O。例如，可以启动计时器在超时过后关闭套接字。或者，如果您想要对中断敏感的无限期超时（例如，由于用户按下“取消”按钮），您可以提交一个无限期等待但通过关闭套接字来响应中断的任务。

不幸的是，RESTTemplate的作者似乎没有提供这种功能。