정렬 중에 매우 이상한 NullPointerException

Question

목록에 null 값이 있으므로 null 포인터 예외가 있습니다. adPics. 거의 발생하지 않습니다. 그게 어떻게 가능해?

(병렬로이 코드는 이미지를 다운로드하고 로컬로 저장합니다.)

List<String> downloadAdImages(List<String> imagesUrls, final String itemFolder) { 
     final List adPics = new ArrayList<>(); 
     final ExecutorService executor = newFixedThreadPool(20); 
     imagesUrls.forEach(
       picUrl -> executor.submit(() -> { 
        try { 
         String imageNewFileName = imagesUrls.indexOf(picUrl) + "." + getExtension(picUrl); 
         String bigPicUrl = picUrl.replace("b.jpg", "ab.jpg"); // big version 
         copyURLToFile(new URL(bigPicUrl), new File(itemFolder, imageNewFileName), 10, 10); 
         adPics.add(imageNewFileName); 
        } catch (IOException ex) { 
         log.log(Level.WARNING, "Could not download image {0} ({1})", new Object[]{picUrl, ex.getMessage()}); 
        } 
       })); 
     executor.shutdown(); 
     try { 
      executor.awaitTermination(15L, MILLISECONDS); 
     } catch (InterruptedException ex) { 
      log.log(Level.WARNING, "Could not wait for all images downloads"); 
     } 
     Collections.sort(adPics); // null values at list lead to NPE here. How are there null values? 
     return adPics; 
    } 

때때로 adPics 목록 null 값이 있습니다. 그것이 NPE의 이유입니다. 그러나 어떻게? 스레드에서 실행 된 코드를 분석하면 null 값을 추가 할 수 없습니다. 이미지를 다운로드 할 때 문제가 발생하면 IOException이 발생합니다. imageNewFileName은 null 일 수 없습니다.

이 코드는 Java 8이며 Apache Commons IO lib를 사용합니다.

Answer 1

awaitTermination 메서드는 실행중인 스레드를 중지하지 않습니다. 모든 스레드가 완료되거나 timeout에 도달 할 때까지 기다립니다. 그러므로 스레드는 여전히 목록에 항목을 추가합니다.

또한 제한 시간에 도달해도 파일 시스템으로 다운로드 및 복사가 실행 중임을 고려해야합니다.

간단하지만 완벽한 해결책은 시간 초과에 도달하면 플래그를 설정하고 항목을 추가하기 전에 플래그를 확인하는 것입니다.

보다 나은 방법은 제한 시간에 도달 한 후에 스레드를 인터럽트하는 것입니다. 또한 다운로드 및 파일 복사를 중단해야합니다.

Answer 2

코드에 몇 가지 문제가 있습니다. 바울은 이미 한 가지 문제를 지적했습니다. 다른 문제는 List adPics에 동시에 액세스한다는 것입니다.

동기화 된 목록을 사용하지 않고 문제를 해결하려면 List [CompletableFuture]를 만들고 CompletableFuture.allOf의 전화를 걸면됩니다. 각 CompletableFuture는 이미지 파일 이름을 반환해야하지만 이미지 다운로드를 시도하기 전에 시간을 확인하여 해당 작업을 시작할지 확인해야합니다. 그렇지 않으면 null 값으로 CompletableFuture를 완료 할 수 있습니다. CompletableFuture.allOf에서 null 값없이 새 List를 만들고 그 목록을 정렬 할 수 있습니다.