왜 내 threadExecutor가 동일한 콜백을 두 번 호출합니까?

Question

이 코드가 있습니다

public <T> T executeCodeBlockWithTimeLimit(String criticalBlockTimeOutMilli, Callable<T> callable) throws 
     Exception { 
    ExecutorService service = Executors.newSingleThreadExecutor(); 
    Future<T> future = service.submit(callable); 

    startStopWatch(); 
    T result; 

    if (criticalBlockTimeOutMilli != null) { 
     result = future.get(Long.parseLong(criticalBlockTimeOutMilli), TimeUnit.MILLISECONDS); 
    } else { 
     result = callable.call(); 
    } 
    long timeElapsed = stopStopWatch(); 
    e2eResult.runTime = timeElapsed; 
    service.shutdown(); 
    return result; 
} 

및 외부 방법 :

Callable<Void> callable = new 
      Callable<Void>() { 
       @Override 
       public Void call() throws 
         Exception { 

        System.out.println("22222"); 

        return null; 
       } 
      }; 
    timerUtils.executeCodeBlockWithTimeLimit(criticalBlockTimeOutMilli, callable); 

그리고 나는 콘솔 인쇄

22222 
22222 

왜 두 번이라고 볼 수?

Answer 1

당신은 submit와 함께 집행자에서 미래을 얻을 때 이 메소드는 Callable 오브젝트 메소드를 호출하고 결과를 저장합니다. 코드에서 먼저 Future을 얻고 변수 criticalBlockTimeOutMilli이 null이면 Callable 객체에서 call() 메서드를 호출합니다. 이는 호출 가능 개체를 두 번 실행한다는 의미입니다.

미래 개체 (이미 Future#get() method 참조)의 이미 수집 된 결과를 사용하므로 get() 메서드를 사용해야합니다.

Answer 2

아마 ExecutorService, 여기 당신을 위해 명확하지 않다 참조를위한 Javadoc의 : http://docs.oracle.com/javase/7/docs/api/java/util/concurrent/ExecutorService.html#submit(java.util.concurrent.Callable)

당신이 실행 프로그램 서비스가 당신을 위해 당신의 호출을 호출합니다 submit(Callable)를 호출 할 때. 당신도 그것을 호출 할 필요가 없습니다. criticalBlockTimeOutMilli가 널이면

Answer 3

다음 실행 프로그램)은 (일단 호출하고

= callable.call 결과를 호출;

은 두 번째로 호출합니다. criticalBlockTimeOutMilli 가정

(?)

Answer 4

if (criticalBlockTimeOutMilli != null) { 
    result = future.get(Long.parseLong(criticalBlockTimeOutMilli), TimeUnit.MILLISECONDS); 
} else { 
    result = future.get(); 
} 

Answer 5

는 두 번 호출 방법을 요구하고, null로 설정됩니다.

Future<T> future = service.submit(callable); 

을 그리고 당신은 다음과 같이 호출 방법을 통해 호출 : 다음과 같이 실행 프로그램 서비스를 통해 방법을 제출 한

result = callable.call();