C# WPF .NET 8.0で期待通りにTask.WaitAll()が動きません。
やりたいこと
定周期タスクの中で以下の動きをしています。
- ある条件Aを満たしたときにメソッドCを非同期で実行開始します。このときCにCancellationTokenを渡します
- ある条件Bを満たしたときに非同期で以下の順序で処理を起動します。
2-1. CancellationTokenのCancelメソッドを呼ぶ
2-2. Task.WaitAllでCの終了を待つ。
2-3. C終了後の処理を行う
期待動作
メソッドCの処理が完了したあとに、2-3.の処理が行われる。
発生現象
2-3.の処理が完了したあとにCの処理が完了する
再現コード
WPFアプリを新規作成してMainWindow.xaml.csに以下を記述します。
using System.Diagnostics;
using System.Text;
using System.Windows;
using System.Windows.Controls;
using System.Windows.Data;
using System.Windows.Documents;
using System.Windows.Input;
using System.Windows.Media;
using System.Windows.Media.Imaging;
using System.Windows.Navigation;
using System.Windows.Shapes;
namespace WpfAndTask
{
/// <summary>
/// Interaction logic for MainWindow.xaml
/// </summary>
public partial class MainWindow : Window
{
static private object _lock = new();
static int num = 0;
static Timer timer2;
static Timer timer1;
static CancellationTokenSource _cts = new CancellationTokenSource();
static List<Task> taskList = new List<Task>();
private const int threadNum = 200;
static List<(string, Action<string, bool, CancellationToken>)> _actions = new List<(string, Action<string, bool, CancellationToken>)>();
private static void timerproc1(object obj)
{
var list = _actions.FindAll(x => x.Item1 == "test");
foreach (var action in list)
{
var task = Task.Run(() => {
action.Item2(action.Item1, true, _cts.Token);
});
taskList.Add(task);
}
}
private static void timerproc2(object state)
{
Task.Run(async () => {
Debug.WriteLine("All tasks started.");
_cts.Cancel();
await Task.WhenAll(taskList.ToArray());
Debug.WriteLine($"num = {num}");
});
}
static void TaskMain()
{
for (int i = 0; i < threadNum; i++)
{
_actions.Add(new("test", AsyncMethod));
}
timer1 = new Timer(timerproc1, null, TimeSpan.FromSeconds(1), TimeSpan.Zero);
timer2 = new Timer(timerproc2, null, TimeSpan.FromSeconds(2), TimeSpan.Zero);
while (true)
{
Task.Delay(100);
}
}
static async void AsyncMethod(string key, bool value, CancellationToken token)
{
try
{
await Task.Delay(100000, token); // 仮の非同期処理
Debug.WriteLine($"AsyncMethod1 completed with argument: {key} {value}");
}
catch
{
lock (_lock)
{
num++;
}
if (num == threadNum)
{
Debug.WriteLine($"AsyncMethod1 Canceled. {key} = {num}");
}
return;
}
}
public MainWindow()
{
InitializeComponent();
TaskMain();
}
}
}