ExecutorService가있는 Java의 다중 스레드 코드가 반환되지 않습니다. 그 이유는 무엇입니까?

Question

잘 작동하는 코드베이스의 다른 곳에서는 매우 비슷한 다중 스레드 코드가 있지만 여기서 잘못된 점을 알 수는 없습니다.

이것은 검색 쿼리에 대한 결과 XML을 생성하는 간단한 멀티 스레드 프로세스입니다. 이 방법을 실행의 출력은 다음과 같습니다

스레드

라인에서 System.out.println ("완료 멀티 스레딩 루프")에서 반환; "에 도달하지 않습니다

수를 수정. 스레드의 도움이되지 않습니다

private void fillAllResults() { 
     int threads = 2; 
     final FutureTask[] tasks = new FutureTask[threads]; 
     final ExecutorService executor = Executors.newCachedThreadPool(); 
     for (int i = 0; i < allResults.size(); i++) { 
      tasks[i] = new FutureTask<Integer>(new Callable<Integer>() { 
       public Integer call() throws Exception { 
        int index; 
        while ((index = getResultsIndex()) < allResults.size()) { 
         System.out.println("Processing result " + index); 

         Result result = allResults.get(index); 
         fillResultXML(result); 
        } 
        System.out.println("Returning from threads"); 
        return 1; 
       } 
      }); 
      executor.execute(tasks[i]); 
     } 
     for (int i = 0; i < threads; i++) { 
      try { 
       tasks[i].get(); 
      } catch (InterruptedException e) { 
       e.printStackTrace(); 
      } catch (ExecutionException e) { 
       e.printStackTrace(); 
      } 
     } 
     executor.shutdown(); 

     System.out.println("Finished multithreading loop"); 
    } 

편집, 모든 빠른 답변 주셔서 감사합니다 여기에 대한 답변을 다음과 같습니다.!

을

'처리 결과'가 여러 번 표시됩니다. allResults.size()가 25 인 경우, 처리 결과 (1), 처리 결과 2 ... 처리 결과를 보여줍니다 (24)

여기에 실종 여분의 코드입니다 :

private List<Result> allResults = new ArrayList<Result>(); 
private int resultsIndex = 0; 

private synchronized int getResultsIndex() { 
return resultsIndex++; 
} 

그리고 경우에 사람이 궁금있어, I 루프 내의 코드로 인해 allResults의 크기가 증가하지 않는다고 보장 할 수 있습니다.

Answer 1

나는 배열 tasks이의 길이를 가지고, 사실 관계가 가정 threads (즉, 귀하의 경우 2 개) 그러나 당신은 라인 내에서 더 많은 값을 할당

for (int i = 0; i < allResults.size(); i++) { 
    tasks[i] = ... 
    .... 
} 

목록 allResults하는 경우 스레드가 두 개 이상 입력 된 경우 ArrayIndexOutOfBoundsException에 의해 스레드가 중지됩니다. 어쩌면이 코드를 잡아낼 수도 있지만 제시 한 코드 밖에서 제대로 처리하지 마십시오.

Answer 2

무한 루프가 발생하는 모든 루프 이후에 getResultsIndex()가 업데이트되지 않는 것처럼 보입니다.

Answer 3

코드에서 allResults와 getResultsIndex가 무엇인지는 명확하지 않지만 getResultsIndex가 반환하는 내용을 업데이트하지 않는 것으로 보입니다.