【发布时间】：2015-05-31 10:06:06
【问题描述】：
我需要创建一个库，在其中我将具有同步和异步功能。
-
executeSynchronous()- 等到我有结果，返回结果。 -
executeAsynchronous()- 立即返回一个 Future，如果需要，可以在其他事情完成后处理它。
我的图书馆的核心逻辑
客户将使用我们的库，他们将通过传递DataKey builder 对象来调用它。然后，我们将使用该DataKey 对象构造一个 URL，并通过执行它对该 URL 进行 HTTP 客户端调用，在我们以 JSON 字符串的形式返回响应后，我们将把该 JSON 字符串原样发送回我们的客户通过创建DataResponse 对象。有些客户会调用executeSynchronous()，有些可能会调用executeAsynchronous() 方法，所以我需要在我的库中分别提供两种方法。
界面：
public interface Client {
// for synchronous
public DataResponse executeSynchronous(DataKey key);
// for asynchronous
public Future<DataResponse> executeAsynchronous(DataKey key);
}
然后我有我的DataClient，它实现了上面的Client 接口：
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);
} 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;
}
}
我们公司的客户将通过在他们的代码库中使用我的工厂来使用我的库，如下所示 -
// if they are calling `executeSynchronous()` method
DataResponse response = DataClientFactory.getInstance().executeSynchronous(dataKey);
// and if they want to call `executeAsynchronous()` method
Future<DataResponse> response = DataClientFactory.getInstance().executeAsynchronous(dataKey);
为我的库实现同步和异步方法的最佳方式是什么？实施sync call as async + waiting 是个坏主意吗？因为我当前的设置每次调用都会消耗线程池中的一个线程？如果是，那么任何人都可以解释为什么这是一个坏主意，并且会有任何性能问题吗？
根据上述条件，您将如何实现同步和异步方法？做这个的最好方式是什么？这个库将在非常重的负载下使用，它必须很快，这意味着无论我的服务器响应什么都需要时间。
我应该在我的代码库中使用AsyncRestTemplate，这将是异步非阻塞架构吗？
【问题讨论】：
标签： java multithreading performance executorservice resttemplate