我正在尝试以下描述的基于事件的异步示例：https : //docs.microsoft.com/zh-cn/dotnet/standard/asynchronous-programming-patterns/component-that-supports-the-event-based-asynchronous-模式。
PrimeNumberCalculator我写的课程与本文中描述的完全相同。我编写了一个简单的客户端控制台应用程序，以调用Calculate方法，如下所示：
//------------CONSOLE APP MAIN------------
static void Main(string[] args)
{
CalculatePrimeNumbers();
Console.WriteLine("Application will exit here. Press a key");
Console.ReadKey();
}
//------------CALLING CODE-----------
static void CalculatePrimeNumbers()
{
PrimeNumberCalculator primeNumberCalculator = new PrimeNumberCalculator();
//setup event handlers
primeNumberCalculator.CalculatePrimeCompleted +=
new CalculatePrimeCompletedEventHandler(primeNumberCalculator_CalculatePrimeCompleted);
primeNumberCalculator.ProgressChanged +=
new ProgressChangedEventHandler(primeNumberCalculator_ProgressChanged);
for (int i = 0; i < 100; i++)
{
Random rand = new Random();
int testNumber = rand.Next(200);
Thread.Sleep(20);
Guid taskId = Guid.NewGuid();
Console.WriteLine($"{taskId} - Starting for {testNumber}");
primeNumberCalculator.CalculatePrimeAsync(testNumber, taskId);
}
}
//------------CALCULATION COMPLETED EVENT HANDLER------------
static private void primeNumberCalculator_CalculatePrimeCompleted(
object sender, CalculatePrimeCompletedEventArgs e)
{
//await Task.Yield();
Guid taskId = (Guid)e.UserState;
Console.WriteLine($"{taskId} - Whole process completed");
}
//------------CALCULATION PROGRESSED EVENT HANDLER------------
static private void primeNumberCalculator_ProgressChanged(ProgressChangedEventArgs e)
{
Guid taskId = (Guid)e.UserState;
Console.WriteLine($"{taskId} - {e.ProgressPercentage}%");
DoSomethingImportant(taskId);
}
//------------POST PROCESSING WORK------------
static void DoSomethingImportant(Guid guid)
{
//necessary Work to be done on completion/progress;
}
当我运行此代码时，代码将按预期的方式工作，但是在处理了许多进度和已完成的事件之后，在应用程序退出该行之后会处理一些事件 Console.WriteLine("Application will exit here. Press a key");
3d744ab4-6d2c-4949-a1ec-ce22718daa1f - Starting for 169
d73dc2c4-a93b-49a2-8608-b2d180884295 - 69%
d73dc2c4-a93b-49a2-8608-b2d180884295 - 77%
d73dc2c4-a93b-49a2-8608-b2d180884295 - 80%
2ae4ab62-1479-4360-8e35-fdf747ed3f93 - 8%
f48a77d5-e349-4ff5-889d-c019c759a527 - Starting for 34
Application will exit here. Press a key
2ae4ab62-1479-4360-8e35-fdf747ed3f93 - 78%
f48a77d5-e349-4ff5-889d-c019c759a527 - 50%
f48a77d5-e349-4ff5-889d-c019c759a527 - 55%
f48a77d5-e349-4ff5-889d-c019c759a527 - 67%
f48a77d5-e349-4ff5-889d-c019c759a527 - 85%
f48a77d5-e349-4ff5-889d-c019c759a527 - 91%
f48a77d5-e349-4ff5-889d-c019c759a527 - Whole process completed
f48a77d5-e349-4ff5-889d-c019c759a527 - 14%
2ae4ab62-1479-4360-8e35-fdf747ed3f93 - 13%
d73dc2c4-a93b-49a2-8608-b2d180884295 - 4%
2ae4ab62-1479-4360-8e35-fdf747ed3f93 - 15%
f48a77d5-e349-4ff5-889d-c019c759a527 - 38%
f48a77d5-e349-4ff5-889d-c019c759a527 - 20%
f48a77d5-e349-4ff5-889d-c019c759a527 - 32%
在上面的输出中，在该"Application will exit here. Press a key"行之后处理了多个事件，这将有效地跳过事件处理程序为这些任务进行的任何后处理。
这是预期的还是我在处理程序中缺少了某些内容？我想避免这种情况的一种方法是跟踪正在执行的计算（任务）的数量，在引发“已完成”事件处理程序时将其选中，然后坚持应用程序直到所有机上计算已完成。
有没有推荐的方法来确保所有事件在应用程序退出之前得到处理？
基于事件的异步编程模式依靠事件来告诉您作业何时完成。您的Main代码中没有任何内容可以告诉它等待所有完成事件触发。
您可以使用CountdownEvent来做到这一点。从100开始计数：
static CountdownEvent cde = new CountdownEvent(100);
primeNumberCalculator_CalculatePrimeCompleted通过调用减去一个Signal()：
cde.Signal();
然后等待，直到方法中的计数为0 Main：
cde.Wait();
另一个选择是改为使用基于任务的异步模式。然后，您可以保留所有任务的列表，并用于Task.WhenAll异步等待它们。本文也可以提供帮助：使用async和await进行异步编程。
本文收集自互联网，转载请注明来源。
如有侵权，请联系[email protected] 删除。
我来说两句