업로드가 완료된 후 ResumableGDataFileUploader가 종료되지 않습니다.

Question

비디오 업로드를 위해 ResumableGDataFileUploader를 구성 할 때 내 프로그램 업로드가 완료된 후에도 끝나지 않습니다. 나는 그것을 죽일 수있는 방법을 찾아 내려고 노력했지만 지금까지는 행운이 없다. 어떻게해야합니까?

private String postYoutubeVideo() throws IOException, ServiceException, GeneralSecurityException, InterruptedException, ExecutionException, TimeoutException { 

    String resumableVideoUploadURL = "http://uploads.gdata.youtube.com/resumable/feeds/api/users/default/uploads"; 
    // constants 

    UploadProgressListener progressListener = new UploadProgressListener(); 
    YouTubeService service = getYouTubeService();  
    File file = getFile(); 
    String mimeType = new MimetypesFileTypeMap().getContentType(file); 
    MediaFileSource mediaFile = new MediaFileSource(file, mimeType); 
    VideoEntry newEntry = new VideoEntry(); 
    YouTubeMediaGroup mediaGroup = newEntry.getOrCreateMediaGroup(); 

    mediaGroup.addCategory(new MediaCategory(YouTubeNamespace.CATEGORY_SCHEME, category)); 
    mediaGroup.addCategory(new MediaCategory(YouTubeNamespace.DEVELOPER_TAG_SCHEME, devtag)); 
    mediaGroup.setTitle(new MediaTitle()); 
    mediaGroup.getTitle().setPlainTextContent(title); 
    mediaGroup.setKeywords(new MediaKeywords()); 
    mediaGroup.getKeywords().addKeyword(keyword); 
    mediaGroup.setDescription(new MediaDescription()); 
    mediaGroup.getDescription().setPlainTextContent(description); 
    mediaGroup.setPrivate(false); 
    newEntry.setMediaSource(mediaFile); 

    ResumableGDataFileUploader resumableUploader = new ResumableGDataFileUploader.Builder(service, new URL(
     resumableVideoUploadURL), mediaFile, newEntry) 
     .title(title) 
     .chunkSize(chunkSize) 
     .build(); 

    resumableUploader.start(); 

    while (!resumableUploader.isDone()) 
    { 
     Thread.sleep(progressInterval); 
    } 

    ResponseMessage response = resumableUploader.getResponse(); 
    VideoEntry newVideo = new VideoEntry(); 
    newVideo.parseAtom(new ExtensionProfile(), response.getInputStream()); 
    extMsgId = newVideo.getHtmlLink().getHref(); 


    return extMsgId; 
} 

Answer 1

문제는 생성 된 ExecutorService 인스턴스에서 shutdown()이 호출되지 않았습니다. 그래서 빌더에게 우리 자신의 집행자를 제공하고 작업이 끝난 후에 종료합니다.

..... 

ExecutorService executorService = Executors.newSingleThreadExecutor(); 

..... 

ResumableGDataFileUploader resumableUploader = new ResumableGDataFileUploader.Builder(service, new URL(
resumableVideoUploadURL), mediaFile, newEntry) 
    .title(title) 
    .chunkSize(chunkSize) 
    .executor(executorService) 
    .build(); 

resumableUploader.start(); 

while (!resumableUploader.isDone()) { 
    Thread.sleep(progressInterval); 
} 

if (ResumableHttpFileUploader.UploadState.COMPLETE.equals(resumableUploader.getUploadState())) { 
    ResponseMessage response = resumableUploader.getResponse(); 
    VideoEntry newVideo = new VideoEntry(); 
    newVideo.parseAtom(new ExtensionProfile(), response.getInputStream()); 
    extMsgId = newVideo.getHtmlLink().getHref(); 
} 

executorService.shutdown(); 

.....