Java의 util을 간략하게 분석합니다.concurrent.Future 인터페이스
public String downloadContents(URL url) throws IOException {
try(InputStream input = url.openStream()) {
return IOUtils.toString(input, StandardCharsets.UTF_8);
}
}
//...
final Future<String> contents = downloadContents(new URL("http://www.example.com"));
Future
public static Future<String> startDownloading(URL url) {
//...
}
final Future<String> contentsFuture = startDownloading(new URL("http://www.example.com"));
//other computation
final String contents = contentsFuture.get();
Future.get () 가 가장 중요한 방법입니다.약속한 결과가 사용 가능한 상태가 될 때까지 막고 기다립니다. 따라서 이 문자열이 필요하면 get () 방법을 사용해서 기다립니다.시간 초과 파라미터를 받아들이는 리셋 버전이 하나 더 있습니다. 문제가 생기면 계속 기다릴 필요가 없습니다. 설정 시간이 지나면 Timeout Exception을 던집니다.
어떤 경우, 당신은 끊임없이 Future가 사용할 수 있는지 몰래 보고 싶을 수도 있습니다.이것은 isDone () 을 통해 완성할 수 있습니다.사용자가 어떤 비동기적인 계산을 기다리고 있는 상황을 상상해 보세요. 이런 상황을 알게 하고 다른 계산을 하고 싶습니다.
final Future<String> contentsFuture = startDownloading(new URL("http://www.example.com"));
while (!contentsFuture.isDone()) {
askUserToWait();
doSomeComputationInTheMeantime();
}
contentsFuture.get();
futrues를 취소하는 것이 마지막입니다. 아직 덮어쓰지 않은 것입니다.비동기적인 작업을 시작하고 2초 후에 우리가 포기하거나 오류를 전달하거나 임시 방안으로 해결할 수 있는 시간을 기다릴 수밖에 없다고 상상해 보세요.그러나 당신은 좋은 시민입니다. 당신은 이future 대상에게 말해야 합니다. 저는 당신을 필요로 하지 않습니다. 상관하지 마세요.그러면 당신은 유행이 지난 임무를 멈추고 자원을 절약할 수 있습니다.구문은 간단합니다.
contentsFuture.cancel(true); //meh...
그래서 우리는 이제 Future가 무엇인지 알게 되었다. - 하나의 자리 표시자, 당신은 미래에 목표 대상을 얻을 수 있다.마치 차 한 대에 대해 아직 만들어지지 않은 열쇠와 같다.그러나 당신은 어떻게 해야만 응용 프로그램에서 Future의 실례를 얻을 수 있습니까?두 가지 가장 일반적인 자원은 스레드 탱크와 비동기 방법 (스레드 탱크 지원) 이다.따라서 startDownloading() 메서드는 다음과 같이 다시 쓸 수 있습니다.
private final ExecutorService pool = Executors.newFixedThreadPool(10);
public Future<String> startDownloading(final URL url) throws IOException {
return pool.submit(new Callable<String>() {
@Override
public String call() throws Exception {
try (InputStream input = url.openStream()) {
return IOUtils.toString(input, StandardCharsets.UTF_8);
}
}
});
}
너는 스프링에서 EJB와 Future를 만날 수도 있다.예를 들어 Spring 프레임워크에 @Async 메모를 추가할 수 있습니다.
@Async
public Future<String> startDownloading(final URL url) throws IOException {
try (InputStream input = url.openStream()) {
return new AsyncResult<>(
IOUtils.toString(input, StandardCharsets.UTF_8)
);
}
}
이 내용에 흥미가 있습니까?
현재 기사가 여러분의 문제를 해결하지 못하는 경우 AI 엔진은 머신러닝 분석(스마트 모델이 방금 만들어져 부정확한 경우가 있을 수 있음)을 통해 가장 유사한 기사를 추천합니다:
JPA + QueryDSL 계층형 댓글, 대댓글 구현(2)이번엔 전편에 이어서 계층형 댓글, 대댓글을 다시 리팩토링해볼 예정이다. 이전 게시글에서는 계층형 댓글, 대댓글을 구현은 되었지만 N+1 문제가 있었다. 이번에는 그 N+1 문제를 해결해 볼 것이다. 위의 로직은 이...
텍스트를 자유롭게 공유하거나 복사할 수 있습니다.하지만 이 문서의 URL은 참조 URL로 남겨 두십시오.
CC BY-SA 2.5, CC BY-SA 3.0 및 CC BY-SA 4.0에 따라 라이센스가 부여됩니다.
좋은 웹페이지 즐겨찾기
