C# 複数のスレッドが全部終了するまで待機する方法が知りたい。

Question

提示コードの///コメント部内部のコードですがマルチスレッドですべてのスレッドが終了するまで待機してすべて終わったら次のコードに推移するという処理を書きたいのですが実装方法がわかりません。マルチタスクでいうTask.WhenAllのようなことがしたいです。現状では一つのスレッドですべての処理を行っています。このソフトは音楽ファイルをffmpegでflacを.m4aに変換する処理なのですがマルチスレッドで素早く終らせる方法が知りたいです。

using System;
using System.Diagnostics;
using System.IO;

public class Program
{
    static List<string> dirList = new List<string>();    //ディレクトリパスリスト
    static List<string> filePathList = new List<string>();


    /*########################################################
     * サブディレクトリを再帰的に取得して設定
     #########################################################*/
    private static void GetSubFolderPathList(string rootPath)
    {
        foreach (string path in Directory.GetDirectories(rootPath))
        {
            if (System.IO.Directory.Exists(path) == true)
            {
                dirList.Add(path);
                GetSubFolderPathList(path);
            }
        }
    }

    /*########################################################
     * ディレクトリからファイル名を取得
     #########################################################*/
    public static List<string> GetFilePathList(string dirPath)
    {
        List<string> list = new List<string>();
        foreach (string path in Directory.GetFiles(dirPath))
        {
            //Console.WriteLine("あああ");
            list.Add(path);
        }

        return list;
    }

    /*########################################################
     * 全てのファイルパスを取得
     #########################################################*/
    private static List<string> GetAllFilePath(string rootPath)
    {
        GetSubFolderPathList(rootPath); //サブディレクトリー取得

        //Console.WriteLine("             " + dirList.Count());


        List<string> file = new List<string>();

        if(dirList.Count() == 0)
        {
            dirList.Add(rootPath);
        }

        foreach (string path in dirList)
        {
            List<string> list = GetFilePathList(path);
            file.AddRange(list);
        }

        return file;
    }

    static int threadNum = 0;
    static int threadCount = 0;

    private static async void Run(string filepath)
    {

        Process process = new Process();
        process.StartInfo.FileName = "ffmpeg.exe";
        process.EnableRaisingEvents = true;
        process.StartInfo.CreateNoWindow = true;            //コンソール・ウィンドウを開かない
        process.StartInfo.UseShellExecute = false;          //シェル機能を使用しない
        process.StartInfo.RedirectStandardOutput = true;
        process.StartInfo.RedirectStandardError = true;



        string inputPath = filepath;
        inputPath = "\"" + inputPath + "\"";
        string outputPath = Path.ChangeExtension(filepath, ".m4a");
        outputPath = "\"" + outputPath + "\"";

        //Console.WriteLine("あああ　" + Path.ChangeExtension(str, ".m4a"));
        process.StartInfo.Arguments = " -y -i " + inputPath + " -c:a alac -c:v copy " + outputPath;

        Console.WriteLine(process.StartInfo.Arguments);

        process.Start();

        //process.WaitForExit();
        //threadNum++;
        Console.WriteLine("ああああ");

    }


    public static void Main()
    {
        

        string rootPath;
        Console.WriteLine("input folder path: ");
        //rootPath = Console.ReadLine().Trim('\"');
        rootPath = "C:\\Users\\yw325\\Desktop\\Blooming Days";

        filePathList = GetAllFilePath(rootPath);   //すべてのファイルパスを取得

 //      Console.WriteLine("filePathList.Count() " + filePathList.Count());


//////////////////////////////////////////////////////////////////////////////////////////////
        List<Thread> thread = new List<Thread>();

            Thread t =  new Thread(new ThreadStart(() =>
            {
                foreach (string str in filePathList)
                {
                    Run(str);
                }

            }));
            

            t.Start();
            t.Join();
//////////////////////////////////////////////////////////////////////////////////////////////
        Console.WriteLine("終了");




    }

}

Comments

[KOZ6.0]

回答に記載しました。

Answer 1

やりたいことは、起動したプロセスがすべて終了するまで待つことでしょうから、Process.Start から Process.WaitForExit を Task としてリスト化し Task.WhenAll でしょう。

プロセスをたくさん起動してしまうと、かえって遅くなるので、セマフォを使って同時に起動するプロセスを制限すると良いと思います。

static void Main() {
    // 略
    using (var slim = new SemaphoreSlim(3)) { // 同時実行数を 3 とします。
        List<Task> tasks = new List<Task>();
        foreach (var str in filePathList) {
            Task task = Task.Factory.StartNew(() => { Run(slim, str); });
            tasks.Add(task);
        }
        Task.WhenAll(tasks).Wait();
    }
}

static void Run(SemaphoreSlim slim, string filepath) {
    slim.Wait();
    try {
        //(略)
        process.Start();
        process.WaitForExit();

    } finally {
        slim.Release();
    }
}

Comments

[退会済みユーザー]

なるほど。ありがとうございます。質問ですが適正なプロセス数はどうやって算出すればいいのでしょうか？

[KOZ6.0]

PC の性能で違ってくるので、デフォルト値を決めておき、パラメタで変更できるようにしておけばいいと思います。

[退会済みユーザー]

ありがとうございます。質問ですがこのアプリは音声ファイルコンバーターなのでマルチスレッドのほうが早くなると思うのですが。その点はどうなのでしょうか？これはマルチプロセスだと思うのですが？

[KOZ6.0]

便乗質問はやめてほしいです。
まぁ、場合による、としかいいようがありません。
たしかにマルチスレッドのほうが起動は軽いですが、１プロセスで使用できるリソースには制限がありますから、動画の編集といった重い処理だと、マルチプロセスで動かしたほうがいい結果が得られるかもしれません。
その辺は観察してみるしかないと思います。

[KOZ6.0]

音声ファイルの変換ソフトに xrecode (https://xrecode.com/) というのがあるんですが、一部の変換を nero や qaac といった exe を起動して行っています。
どのくらいの大きさのファイルをどのくらいの時間で処理できるかの目安になるので是非つかってみてください