同時に複数のスレッドを実行させる。

Question

private void main()
{
bool flag1 = await test1();
bool flag2 = await test2();
if (flag1 && flag2)
{
// next step
}
else if (flag2)
{
// test2()を再度実行（flag2がtrueになるまで実行する）
}
else if (flag2)
{
// test1()を再度実行（flag1がtrueになるまで実行する）
}
}

private async Task<bool> test1()
{
return await System.Threading.Tasks.Task.Run(() =>
{
try
{
Thread.Sleep(5000);
return true;
}
catch
{
return false;
}
});
}

private async Task<bool> test2()
{
return await System.Threading.Tasks.Task.Run(() =>
{
try
{
Thread.Sleep(3000);
return true;
}
catch
{
return false;
}
});
}

書き方がまちがえているというよりは、やりたいことだと思っていただけるとたすかります。
上記のようにそれぞれ時間のかかる処理を同時にバックグラウンドで実行させ、全ての処理が終わったらその結果を元に次のステップに移りたい場合、どういうやり方が正しいのかわかりません。
どうぞご教授お願いします。
ちなみに、それぞれの処理というのは各種データなどをファイルなどからそれぞれ取得してくるなどのことです。
また、この場合、各種データはデータ間での干渉はないのですが、それらのデータがすべてないと次のステップに進むことができない。とお考えいただければと思います。

Answer 1

最近 Thread は流行らないみたいですが、こんなんいかがでしょうか。

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading;

namespace t23437
{
	class Program
	{
		static void Main(string[] args)
		{
			new Program().main();
		}

		private void main()
		{
			Thread th1 = new Thread((ThreadStart)delegate
			{
				while (test1() == false) ;
			});
			th1.Start();
			while (test2() == false) ;
			th1.Join();
		}

		private bool test1()
		{
			try
			{
				Thread.Sleep(5000);
				return true;
			}
			catch
			{
				return false;
			}
		}

		private bool test2()
		{
			try
			{
				Thread.Sleep(3000);
				return true;
			}
			catch
			{
				return false;
			}
		}
	}
}

Comments

[takagi.1994]

ありがとうございます。
しっかり読んで勉強させていただきます。

Answer 2

「やりたいこと」と思われることをそのまま実装すると、こんな感じになると思います。

private void main()
{
	var task1 = Task.Run<bool>(new Func<bool>(test1));
	var task2 = Task.Run<bool>(new Func<bool>(test2));
	Task.WaitAll(task1, task2);
	while(!task1.Result || !task2.Result)
	{
		if(!task1.Result)
		{
			task1 = Task.Run<bool>(new Func<bool>(test1));
		}
		if(!task2.Result)
		{
			task2 = Task.Run<bool>(new Func<bool>(test2));
		}
		Task.WaitAll(task1, task2);
	}

	// next step
}

private bool test1()
{
	try
	{
		Thread.Sleep(5000);
		return true;
	}
	catch
	{
		return false;
	}
}

private bool test2()
{
	try
	{
		Thread.Sleep(3000);
		return true;
	}
	catch
	{
		return false;
	}
}
```タスクは成功するまで繰り返し実行する必要があるということなので、mainメソッドをこのような書き方にしましたが、できればtest1/test2メソッド内で繰り返させた方が呼び出し側のコードを簡潔にできると思います。

Answer 3

こんにちは。

バックグラウンドスレッドで同期を取りつつ並列処理をしたい、
ということだと解釈しました。（間違ってたすみません。）

button1_clickをmain()と読み替えてもらえたら。
async/awaitで非同期処理を1本つくって、その中でTPLで並列処理します。

それぞれの処理が終わった後の「次の処理」をメインスレッドで実行したい場合はbutton1_Click内のawaitの後に実行したら良いです。

private async void button1_Click(object sender, EventArgs e)
{
    await Task.Run(() =>
    {
        Console.WriteLine("button1.start");
        Parallel.Invoke(hoge1, hoge2);
        Console.WriteLine("button1.end");
    });
}

private void hoge1()
{
    Console.WriteLine("hoge1.start");
    Thread.Sleep(5000);
    Console.WriteLine("hoge1.end");
}

private void hoge2()
{
    Console.WriteLine("hoge2.start");
    Thread.Sleep(3000);
    Console.WriteLine("hoge2.end");
}

これ以外の方法でも、同期コンテキストを使って待たせればいくらでも実現する方法はありそうです。

Comments

[takagi.1994]

早速のご回答ありがとうございます。
スキル不足で内容がぴんときていないのですが、この場合、戻り値によってその語の処理を変えたりしたい場合はどうなるのでしょうか？
また、同期コンテキストなるものの理解がググってもいまいち理解できないんです。
すいません。

[Tak1wa]

https://msdn.microsoft.com/ja-jp/library/dd460721%28v=vs.110%29.aspx?f=255&MSPPError=-2147217396

何をやりたいのかによりますが、Parallel.Invoke処理をParallel.ForEachで実行し戻り値によって処理を中断したり分岐させれば良いかもしれません。