thread.pool で全部が終わるまで処理を待機させる方法が知りたい。

Question

###やりたい事
スレットプールExecutorService を使って全てのタスクが終了するまで処理を待機させる方法が知りたい。

###現状
現状はスレッドプールを使って大量の画像データを一つのpdfファイルに変換する処理を実装しているのですが処理が流れてしまい困っています。

###質問内容
提示コードのここですの/////コメント部に.Wait();のような処理を待機させる関数が知りたいです。
awaitTermination()関数は一定時間経過するかタイムアウトするまで処理をブロックできますが終わるまで永遠と待機させる方法はあるのでしょうか？

###調べたこと
参考サイトA: https://javazuki.com/articles/executor-framework-usage.html#_%E3%82%B9%E3%83%AC%E3%83%83%E3%83%89%E3%83%97%E3%83%BC%E3%83%AB%E3%81%AE%E7%94%9F%E6%88%90%E3%81%A8%E3%82%B9%E3%83%AC%E3%83%83%E3%83%89%E3%81%AE%E5%AE%9F%E8%A1%8C

参考サイトB: https://docs.oracle.com/javase/jp/16/docs/api/java.base/java/util/concurrent/package-summary.html

参考サイトC: https://docs.oracle.com/javase/jp/8/docs/api/java/util/concurrent/ExecutorService.html

import java.io.*;
import java.io.IOException;
import java.util.ArrayList;
import java.util.List;
import java.util.Scanner;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

import org.apache.pdfbox.pdmodel.PDDocument;
import org.apache.pdfbox.pdmodel.PDPage;
//import org.apache.pdfbox.pdmodel.PDPageContentStream;
//import org.apache.pdfbox.pdmodel.common.PDRectangle;
//import org.apache.pdfbox.pdmodel.graphics.image.PDImageXObject;


public class Main 
{	
	
	public static void main(String args[]) 
	{	
		final int threadNum = 8;	//スレッド数


		Scanner scanner = new Scanner(System.in);	

		System.out.println("windows: Ctrl + Z 開始");
		System.out.println("linux:   Ctrl + D 開始\n");
		
		List<File> file = new ArrayList<>();				//ディレクトパス
		List<ConvertDirectory> dirList = new ArrayList<>();	//変換ディレクトリ

		while(true)
		{			
			System.out.print("\nDirectory　or File > ");		
			if(scanner.hasNextLine() == false) { break; }				
			String fileName = scanner.nextLine();			
			file.add(new File(fileName));	
		}
		
		ExecutorService pool = Executors.newFixedThreadPool(threadNum);

		for(File f : file)
		{
			dirList.add(new ConvertDirectory(f,threadNum,pool));
		}

		for(ConvertDirectory c : dirList)
		{
			c.Start();
		}				

		/////////////////////////////////////////////////
		// ここ
		/////////////////////////////////////////////////
		

		System.out.println("\n\n\n\n\n全部終了");

		pool.shutdown();	//スレッドプールを閉じる
	scanner.close(); 		//scanner close
	}
}

Comments

[Zuishin]

同じ質問を見た。

[退会済みユーザー]

この場合また違うやり方だと思うのですが

Answer 1

提示コードのように一度shutodonw();させてから全てのタスクが終了するかタイムアウトするまで待機するという処理で実現できまました。

for(ConvertDirectory c : dirList)
{
	c.Start();        
}

try
{
	pool.shutdown();	//スレッドプールを閉じる
    pool.awaitTermination(Long.MAX_VALUE, TimeUnit.NANOSECONDS);            	
}
catch(InterruptedException e)
{
	e.printStackTrace();
}