C# と VB.NET の質問掲示板

ASP.NET、C++/CLI、Java 何でもどうぞ

C# と VB.NET の入門サイト

Re[9]: マルチスレッドについて教えてください。

分類:[.NET 全般]　

スレッドのテストプログラムを作ってみました。

目的はAsyncTest1()とAsyncTest2()を非同期に同時処理を
行うことです。
理由は
①AsyncTest1で３秒、AsyncTest2で４秒かかるとすると
通常だと７秒かかるので、タスク処理させると
AsyncTest2 の４秒に近い処理で２つの処理を
行うことができるという考えです。

そこで、以下のように作ってみました。
思うようにとりあえずは動作しました。

　public partial class Form1 : Form
　{
　　bool flag1 = false;
　　bool flag2 = false;

　　public Form1()
　　{
　　　InitializeComponent();
　　}

　　private void button1_Click(object sender, EventArgs e)
　　{
　　　flag1 = flag2 = true;

　　　AsyncTest1();
　　　AsyncTest2();

　　　while(flag1 || flag2) Application.DoEvents();　⇒②

　　　Console.Write("\r\n終了");
　　}

　　public async void AsyncTest1()
　　{
　　　Random random = new System.Random();
　　　Console.Write("処理１開始\r\n");
　　　int result = random.Next(1000, 5000);
　　　await Task.Run(() =>
　　　{
　　　　Thread.Sleep(result);
　　　});
　　　Console.Write("処理１終了：時間 {0}\r\n", result);
　　　flag1 = false;
　　}

　　public async void AsyncTest2()
　　{
　　　Random random = new System.Random();
　　　Console.Write("処理２開始\r\n");
　　　int result = random.Next(1000, 5000);
　　　await Task.Run(() =>
　　　{
　　　　Thread.Sleep(result);
　　　});
　　　Console.Write("処理２終了：時間 {0}\r\n", result);
　　　flag2 = false;
　　}
　}

ここで、いくつか質問があります。

①目的のためのプログラムの作り方は間違っていないのでしょうか？

②Application.DoEvents() の代わりに
何もできないようにしようと、Continue に変更すると
flag1, flag2 は変更されず無限ループになります。
AsyncTest1(), AsyncTest2() の終了待ちを行うのは
どうすればよいのでしょうか？

③実行先のＰＣが.net 4なので、Task.Run が
使え内容です。 .net 4ようにする場合

Random random = new System.Random();
const int N = 2;
Parallel.For(0, N, id =>
{
　if(id == 0)
　{
　　Console.Write("処理１開始\r\n");
　　int result = random.Next(1000, 5000);
　　Thread.Sleep(result);
　　Console.Write("処理１終了：時間 {0}\r\n", result);
　}
　else
　{
　　Console.Write("処理２開始\r\n");
　　int result = random.Next(1000, 5000);
　　Thread.Sleep(result);
　　Console.Write("処理２終了：時間 {0}\r\n", result);
　}
});

とすればよいのでしょうか?

全体をawaitする形にするのが普通な気がします。

例えばですが、今の例だと、AsyncTest1とAsyncTest2の戻り値をTaskに書き換えて（void→Taskと書き換えるだけ）、呼び出し側ではそれぞれawaitします。

意味的には個別にawaitではなくて、
Task.WhenAll(AsyncTest1(), AsyncTest2());
の方がいいですね多分。

■No77010 (なちゃさん) に返信
> 意味的には個別にawaitではなくて、
> Task.WhenAll(AsyncTest1(), AsyncTest2());
> の方がいいですね多分。

呼び出し側では、
await Task.WhenAll(AsyncTest1(), AsyncTest2());
みたいにするってことです。

画面を触れないようにするには、タスク呼び出し前に例えばフォームのEnabledをFalseにして、全体のawait後にTrueに戻すなどの方法があります。
まあこれをするとフォーム全体が操作不能になるので、本当はもう少し細かく制御する方がいいですが。

.NET Framework 4の場合は…
Taskはまあ明示的に作ればすむ話ですが、awaitが使えないのが非常に面倒です。

■No77009 (なちゃさん) に返信
> 全体をawaitする形にするのが普通な気がします。

　　bool flag = false;
　　private void button3_Click(object sender, EventArgs e)
　　{
　　　flag = true;

　　　AsyncTest3();

　　　while(flag) Application.DoEvents();
　　}

　　public async void AsyncTest3()
　　{
　　　Random random = new System.Random();
　　　Console.Write("処理１開始\r\n");
　　　int result1 = random.Next(1000, 5000);
　　　int result2 = random.Next(1000, 5000);
　　　await Task.Run(() =>
　　　{
　　　　Thread.Sleep(result1);
　　　　Thread.Sleep(result2);
　　　});
　　　Console.Write("処理終了：時間 {0} {1}\r\n", result1, result2);
　　　flag = false;
　　}

まとめましたが
これだと、シングル処理となんら変わりませんでした。
処理に　result1 + result2 の時間がかかりました。
「全体をawaitする形」の意味がちがうのでしょうか？

> まとめましたが
> これだと、シングル処理となんら変わりませんでした。
> 処理に　result1 + result2 の時間がかかりました。
> 「全体をawaitする形」の意味がちがうのでしょうか？

意味が違います。
一例ですがそれ以降の書き込みの具体的な例を見てください。

各タスク内でそれぞれawaitする必要がなければ、普通にWhenAllでawaitするだけです。

■No77017 (なちゃさん) に返信
> 各タスク内でそれぞれawaitする必要がなければ、普通にWhenAllでawaitするだけです。

すみません。いろいろ試しましたが
書き方がわかりません。

Task.WhenAll(AsyncTest1(), AsyncTest2());
この時点で「最も適しているオーバーロードメソッドには無効な引数がいくつか含まれています。」
となってしまいます。

■No77018 (ミーアキャットさん) に返信
> ■No77017 (なちゃさん) に返信
>>各タスク内でそれぞれawaitする必要がなければ、普通にWhenAllでawaitするだけです。

普通にというのは、Taskを普通にWhenAllでawaitするという意味です。
Task.WhenAll(Task.Run(…), Task.Run(…));
みたいに。

今のようなメソッドの構造のままにしたいなら、AsyncTest1などの戻り値をTaskにする必要があります。
メソッド内でawaitするならvoidをTaskに書き換えるだけ、awaitしないならTask.Run()などの戻り値をそのままリターンする感じになります。

> 普通にというのは、Taskを普通にWhenAllでawaitするという意味です。
> Task.WhenAll(Task.Run(…), Task.Run(…));
> みたいに。

おっと、awaitを入れて書いたら
await Task.WhenAll(Task.Run(…), Task.Run(…));
のような感じです。

勉強しながら始めてasync/await使ってみました。
質問者さんの意図に合っていないかもしれませんが、
自身の意図通りには一応動いています。
参考になればいいですが・・・

        private async void button1_Click(object sender, EventArgs e)
        {
            System.Diagnostics.Debug.Print("button1開始");
            button1.Enabled = false;
            var task1 = work1();
            var task2 = work2();
            var task3 = work3();
            System.Diagnostics.Debug.Print("button1終了");
            await Task.WhenAll(task1, task2, task3);
            button1.Enabled = true;
            System.Diagnostics.Debug.Print("全仕事終了");
        }

        public async Task work1()
        {
            System.Diagnostics.Debug.Print("仕事１開始");
            await Task.Run(() => Thread.Sleep(5000));
            System.Diagnostics.Debug.Print("仕事１終了");
        }

        public async Task work2()
        {
            System.Diagnostics.Debug.Print("仕事２開始");
            await Task.Run(() => Thread.Sleep(3000));
            System.Diagnostics.Debug.Print("仕事２終了");
        }

        public async Task work3()
        {
            System.Diagnostics.Debug.Print("仕事３開始");
            await Task.Run(() => Thread.Sleep(1000));
            System.Diagnostics.Debug.Print("仕事３終了");
        }

なちゃさん、kiku さん
どうもありがとうございました。

理解できました。

ただ、やはり、.net4では動作しないので
Thread を使って作ります。

自分のPDで動作させるときには
使いたいと思います。

C# と VB.NET の質問掲示板

ASP.NET、C++/CLI、Java 何でもどうぞ

C# と VB.NET の入門サイト

Re[9]: マルチスレッドについて教えてください。

過去ログには書き込み不可