マルチスレッドで全てを同時開始させて全てが終わるまで待機させたい。

Question

###やりたい事
マルチスレッドを使って全てのスレッドを同時に実行して全てのスレッドが終了するまで待機する処理を作りたです。

###コード内容
pdfの複数のディレクトリをマルチスレッドで処理するコード

###現状
提示コードの下部の//////コメント部内部のコードですが.join()関数を使って終了するまで待機していますがこのやり方だと
スレッドA,BがあるとしてAが実行してAが終了するまでBの処理が始まらず。結果的にAの次がB　という感じで
順番に処理されていまいす。
現在はThreadクラスを継承させて行っています。*

###質問内容
上記のやりたい事を実現するにはどういった手法を行えばいいのでしょうか？Threadクラスを継承するやり方だと現状のようなやりかたになってしまいます。

###参考サイト
参考サイトA：　https://qiita.com/yacchi1123/items/d89edbaf681a630d4343
Github：　https://github.com/Shigurechan/PDFConverter

---

import java.io.File;

import java.util.ArrayList;
import java.util.List;
import java.util.Scanner;

public class Main 
{	
	public static void main(String args[]) 
	{	
		Scanner scanner = new Scanner(System.in);	
		List<Converter> dirList = new ArrayList<>();		//ディレクトリ
		List<ConverterPage> pageList = new ArrayList<>();	//ページ
			
		System.out.println("windows: Cntrl + z 開始");
		System.out.println("linux: Cntrl + D 開始\n");
		
		
		int i = 0;	//表示用
		while(true)
		{
			
			System.out.print("\nDirectory　or File > ");
			
			if(scanner.hasNextLine() == false)
			{
				break;
			}
			
			
			
			String fileName = scanner.nextLine();
			System.out.println(fileName);
			
			File file = new File(fileName);
			
			//System.out.println(file.getName().substring(file.getName().lastIndexOf(".")));
			
			System.out.println(" " + i + " >: " + fileName);
		
			//ファイルかディレクトリかを選別
			if(file.exists() == true)
			{				
				if(file.isFile() == true)
				{
					String extension = file.getName().substring(file.getName().lastIndexOf("."));
					
					if(extension.equals(".png") || extension.equals(".jpg") || extension.equals(".jpeg"))
					{					
						pageList.add(new ConverterPage(fileName));
					}	
				}
				else
				{	
					dirList.add(new Converter(fileName));
				}
			}
			else
			{
				System.out.println("対応形式ではりません: " + file.getName());
			}	
			
			i++;	
		}
		
		
		//ディレクトリ
		if(dirList.size() > 0)
		{
			for(Converter con : dirList)
			{
				con.start();
			}
			
		}
		
		//ファイル
		if(pageList.size() > 0)
		{
			for(ConverterPage con : pageList)
			{
				con.start();
			}	
		}
		
		long startTime = System.currentTimeMillis();	//開始時間
		

		try
		{
//////////////////////////////////////////////////////////////////////////////////////////////
			for(Converter con : dirList)
			{
				con.join();	
			}
//////////////////////////////////////////////////////////////////////////////////////////////			
			for(ConverterPage con : pageList)
			{
				con.join();
			}
		}
		catch(InterruptedException e)
		{
			e.printStackTrace();
		}
		
		
		scanner.close(); //scanner close
		
		long endTime = System.currentTimeMillis();	//終了時間
		System.out.println("終了: " + (endTime - startTime));
	}
}

Comments

[quickquip]

> １番が終了するまで２番が実行されないという状態です
１番 ２番 とはなんのことでしょうか。通じてないのので質問を編集して補足してもらえればと思いました。
また、"１番が終了するまで２番が実行されない"というのは、どう確認して、何を以て判断したのでしょうか。

[cretter]

>*現在はThreadクラスを継承させて行っています。**
と言っていますがこのソースコードは最新のものですか？
ソースコードを見たところ特に間違いは見つけられないのでThreadを継承したクラスのソースコードも乗っけてくれるとありがたいです。

[退会済みユーザー]

https://github.com/Shigurechan/PDFConverter
質問内に追記しました。長いのでGithubです。

[dodox86]

例えば10個のスレッドがあって、それぞれをひとつのループでjoinで待つようにした場合、1つのjoin待ちでブロックしてしまうけど、スレッドが終わったらjoinから抜けてくるわけで、最終的には10個全部終了するまで待機するかたちになるので質問にある要望は満たせるはず。回答を既にいただいていて、その後に質問が編集されているので満足されていないようですが、本当にやりたいことがどうもよく分からない質問ですね。

[quickquip]

> 順番に実行されてしまい
が伝わりません。
これは何かを確認した結果の「質問者さんの解釈」です。
回答者側が欲しいのは質問者さんの解釈ではなくて、"なにをどう確認したのか?"という情報と、それを見て"質問者さんがどう考えて"その解釈に至ったのか? ということです。
それがないと回答ができません（正しくは"回答ができない場合もある"でしょうが、今回はそのケースに当てはまる可能性が高いと感じています）。

> やりたいこととは違います
の"やりたいこと"も伝わってないです。想像はできますが、こういうことがしたいんだろうな程度のものです。

[退会済みユーザー]

なるほどわかりました。

[Zuishin]

なるほどわかりました(何を言われたんだろう？？？？)

[quickquip]

> Aが実行してAが終了するまでBの処理が始まらず
それをどうやって確認したんですか? ということが知りたかった。（けっきょく「なにも確認してないのに妄想的に思い込んでただけ」が正解?）

Answer 1

con.start() , con.join() の後にそれぞれ何かしら文字列を出力してみてください。

con.start();
System.out.println("dir start: " + con.getName());

con.join();
System.out.println("dir end: " + con.getName());

直列実行しているのならば start, end が交互に表示されるはずです。

思い込みで考えるのではなく、実際の挙動を確認するようにしましょう。

Comments

[退会済みユーザー]

なるほど以下のうに実行したらコンストラクタの第一引数は待機するミリ秒です。

```java
test a = new test(41,"aaa");
test b = new test(10,"bbb");
test c = new test(5,"cc");

c.start();
a.start();
b.start();

a.join();
b.join();
c.join();
```

「実行結果」
cc
bbb
aaa
と表示されました
これは”全てのスレッドを同時に開始させて最後が終わるまで待機する”という処理になっているるのでしょうか？

[mather]

「出来ていますか？」と毎回他人に確認するのではなく「期待通りか期待通りでないか」を自分自身で考えてください。
逆に聞きますが、不安に感じる部分はありますか？

[退会済みユーザー]

なんとなく不安なので聞きたくなってしまいました。すいません。確認したかったです。

[mather]

責めているわけではありません。
「なんとなく不安」をもっと具体的に表現しない限り、あなた自身の不安を解消する回答は得られません。
誰かに「正解です」と言ってもらわないと不安だと思うなら、どうやったら「正しく動作した」と確認できるかを考えてみてください。

Answer 2

一斉start・順にjoin で納得されなければ、 CountDownLatch
もあります。

Answer 3

おそらく読まれないとはおもいますが、大量にスレッドを起動するのであれば、java.util.concurrentの参照と利用をおすすめしておきます。

Answer 4

Threadクラスについて調べてみてはどうでしょうか。
Threadのjoin()が役に立つかと。
参考にできそうなURLです

上の回答は間違いです。
少し待っててください。

joinをまとめたクラスをもう一つ作るのはどうでしょうか。そのクラスをThreadを使ってjoinをすればそのクラス内の処理がすべて終わってからなので間違いは起きないかと。