Taskを使った非同期処理で処理が終わった順番に番号を振り表示する方法が知りたい。

Question

提示子ですがマルチタスクで音楽ファイルをエンコードしてするのですが終わった順番から[ 2 / 300] : タイトル　
のように画面に表示させたいのですがどうすればいいのでしょうか？
Task.Runに数字を入れましたが非同期ですので数字がバラバラで順番になりません。これはどうしたらいいのでしょうか？

using System;
using System.Threading.Tasks;
using System.Diagnostics;
using System.IO;
using System.Collections.Generic;

namespace Test
{
    class Program
    {
        //ダブルクォートをつける
        static string AddDoubleQuote(string path)
        {
            return "\"" + path + "\"";
        }

        //ダブルクォートを外す
        static string DeleteDoubleQuote(string path)
        {
            path = path.Replace("\"", "");
            path = path.Replace("\"", "");

            return path;
        }


        //ディレクトリ内部を表示
        static List<string> GetDirectory(string path)
        {
            List<string> name = new List<string>();
            string[] list = Directory.GetFiles(path, "*", SearchOption.AllDirectories);

            foreach (string na in list)
            {
                name.Add(na);
            }

            return name;
        }

        //コマンドを取得
        static string GetCommand(string in_path,string out_path)
        {
            in_path = "\"" + in_path + "\"";

            string ext = Path.GetExtension(in_path);
            ext = ext.Replace("\"", "");
            //Console.WriteLine(ext);
            if (ext == ".flac")
            {
//                Console.WriteLine("ああああ " + ext );
                out_path = "\""+ out_path.Replace(ext, ".m4a");
                

                string command = " -i " + in_path + " -c:v copy -metadata comment=\"\" -acodec alac" + " " + out_path + "\"";
                return command;
            }
            else
            {
                return null;
            }

        }
        ////////////////////////////////////////////////////////////////////////////////////////////////////
        //ファイルをエンコードする
        public static async Task<int> ConvertFile(string in_path,string out_path)
        {
            return await Task.Run(() =>
            {
                Process pro = new Process();

                //エンコードをかける
                string st = GetCommand(in_path,out_path);
                if (st != null)
                {

                    pro.StartInfo.FileName = "ffmpeg.exe";
                    pro.StartInfo.Arguments = st;  //引数
                    pro.StartInfo.CreateNoWindow = true;    //コンソール画面を表示しない。
                    pro.Start();
                    pro.WaitForExit();  //処理を待機
                    //Console.WriteLine("exit code: " + pro.ExitCode);
                    Console.WriteLine(Path.GetFileName(st));

                    int e = pro.ExitCode;
                    pro.Close();

                    return e;
                    //return pro.ExitCode;
                }
                else
                {
            //        Console.WriteLine("Error");
                    return -1;
                }
            });
        
        }
//////////////////////////////////////////////////////////////////////////////////////////////////////////////
        



        static void Main(string[] args)
        {

            //string str = args[0];
            string str = Console.ReadLine();                    //ファイル名をD&D
            str = DeleteDoubleQuote(str);                       //ダブルクォートを外す

            List<string> filePath = GetDirectory(str);          //ディレクトリを取得
            List<string> destPath = new List<string>();         //保存先のパス
            List<Task<int>> tasklist = new List<Task<int>>();   //タスクリスト

            int num = 0;
            foreach (string n in filePath)
            {
                Directory.CreateDirectory(Path.GetDirectoryName(n.Replace(Directory.GetParent(str).FullName, Directory.GetCurrentDirectory())));   //フォルダ作成 
                tasklist.Add(ConvertFile(n, n.Replace(Directory.GetParent(str).FullName, Directory.GetCurrentDirectory())));
            }

            Task.WaitAll(tasklist.ToArray());   //待機
           

            Console.WriteLine("変換終了");

            Console.ReadKey();
        }
    }
}

Comments

[退会済みユーザー]

そもそも何故非同期で実行したいのでしょう？
CPUをフルに使いたいだけなら、ffmpeg自体をマルチスレッドで起動すれば良さそうですが。

[退会済みユーザー]

質問ですがその場合Task処理は外さないといけないのでしょうか？

[退会済みユーザー]

別に使ってもいいですけど、特にメリットはないと思います。（むしろ非同期で処理がややこしくなるのがデメリット）

Answer 1

無理だと思います。どうしても終わった順番を付けたいということなら、非同期をやめて同期に処理する他なさそうです。

Comments

[dodox86]

全体として非同期ではあっても、Lock系のオブジェクトを使うことでほぼ、終わった順に同期的に採番することはできると思いますが、これまでの当質問者さんの問題への向き合い方からすると、残念ながら無理と思える難易度だとは思います。

Answer 2

単純にインクリメントするだけだとダメだったので、Interlocked.Increment メソッドはどうかな？ってやってみたんですが、ダメなんですかね？

using System;
using System.Collections.Generic;
using System.Threading.Tasks;
using System.Threading;

namespace TeraTaskFinishNum {
    class Program {
        public static async Task<int> ConvertFile(string in_path, string out_path) {
            return await Task.Run(() => {
                var r = new Random();
                var t = r.Next(500, 1000);
                System.Threading.Thread.Sleep(t);
                Console.WriteLine("[" + (Interlocked.Increment(ref num)) + "/" + max + "] " + in_path + " " + out_path + " " + t);
                return 1;
            });

        }
        static int num = 0;
        static int max = 0;
        static void Main(string[] args) {
            num = 0;
            max = 300;
            List<Task<int>> tasklist = new List<Task<int>>();
            for (int i = 0; i < max; i++) {
                tasklist.Add(ConvertFile("aaa"+i, "bbb"));
            }
            Task.WaitAll(tasklist.ToArray());
            Console.Read();
        }
    }
}

ご指摘いただいた通りデッドロックしたため、Windowsフォーム版の例を追記しておきます。

using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Text;
using System.Threading;
using System.Threading.Tasks;
using System.Windows.Forms;

namespace MultiTaskIncrement {
    public partial class Form1 : Form {
        public Form1() {
            InitializeComponent();
        }

        int num = 0;
        int max = 0;
        public async Task<int> ConvertFile(string in_path, string out_path) {
            return await Task.Run(() => {
                var r = new Random();
                var t = r.Next(500, 1000);
                System.Threading.Thread.Sleep(t);
                this.Invoke((MethodInvoker)delegate() {
                    listBox1.Items.Add("[" + (Interlocked.Increment(ref num)) + "/" + max + "] " + in_path + " " + out_path + " " + t);
                });
                return 1;
            });
        }

        private async void button1_Click(object sender, EventArgs e) {
            num = 0;
            max = 300;
            List<Task<int>> tasklist = new List<Task<int>>();
            for (int i = 0; i < max; i++) {
                tasklist.Add(ConvertFile("aaa" + i, "bbb"));
            }
            await Task.Run(() => {
                Task.WaitAll(tasklist.ToArray());
            });
            MessageBox.Show("owari");
        }
    }
}

Comments

[Hey_CH]

って、もうベストアンサーついてました。すいません。

[退会済みユーザー]

自分もその後知り合いに聞いてそのやり方見つけました。

[退会済みユーザー]

そのコードは WinForms とか WPF などの GUI アプリではたぶんデッドロックになると思いますのでご注意を。回答のコードはコンソールアプリですのでデッドロックにならなかったということだと理解しています。（プラス評価を付けた手前注意を書かせていただきました）

[Hey_CH]

なるほど、コンソールアプリだからたまたまうまく動いてるって事なんですね。ありがとうございます。