同期メソッドと非同期メソッドを含むライブラリを作成する必要があります。
executeSynchronous()- 結果が出るまで待ち、結果を返します。executeAsynchronous()- 必要に応じて、他の処理が完了した後に処理できる Future をすぐに返します。
ライブラリのコア ロジック
顧客は私たちのライブラリを使用し、DataKeyビルダー オブジェクトを渡すことによってそれを呼び出します。次に、そのオブジェクトを使用して URL を作成し、それを実行してその URL への HTTP クライアント呼び出しを行い、JSON 文字列として応答を取得した後、オブジェクトDataKeyを作成してその JSON 文字列をそのまま顧客に返します。 DataResponse. 一部の顧客から電話がexecuteSynchronous()あり、一部の顧客から電話がかかる可能性がexecuteAsynchronous()あるため、ライブラリで 2 つのメソッドを別々に提供する必要があります。
インターフェース：
public interface Client {
// for synchronous
public DataResponse executeSynchronous(DataKey key);
// for asynchronous
public Future<DataResponse> executeAsynchronous(DataKey key);
}
そして、上記のインターフェースDataClientを実装するmy があります。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);
// does this look right the way I am doing it?
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 個のスレッドの 1 つが長時間占有される可能性があります)。そこで、オンラインでいくつかの調査を行ったところ、以下に示すようcancelに onを使用してタイムアウトになったタスクをキャンセルできることがわかりました-future
future.cancel(true);
しかし、確認したかったexecuteSynchronousのですが、タイムアウトになったタスクをキャンセルするためにメソッドで行っている方法が正しいように見えますか?
タスクがまだキューにある場合に実行を停止する を呼び出しcancel()ているFutureので、自分がしていることが正しいかどうかわかりませんか? これを行うための正しいアプローチは何ですか?
より良い方法があれば、誰かがその例を提供できますか?