- android - 多次调用 OnPrimaryClipChangedListener
- android - 无法更新 RecyclerView 中的 TextView 字段
- android.database.CursorIndexOutOfBoundsException : Index 0 requested, 光标大小为 0
- android - 使用 AppCompat 时,我们是否需要明确指定其 UI 组件(Spinner、EditText)颜色
我正在尝试在以下位置描述的基于事件的异步示例:https://learn.microsoft.com/en-us/dotnet/standard/asynchronous-programming-patterns/component-that-supports-the-event-based-asynchronous-pattern .
我写的PrimeNumberCalculator
类和文中描述的完全一样。我编写了一个简单的客户端控制台应用程序来调用计算方法,如下所示:
//------------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 ("应用程序将在这里退出。按一个键");
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);
通过调用 Signal()
在 primeNumberCalculator_CalculatePrimeCompleted
中减一:
cde.Signal();
然后在 Main
方法中等待计数为 0:
cde.Wait();
另一种选择是使用 Task-based asynchronous pattern反而。然后你可以保留所有任务的列表并使用 Task.WhenAll
异步等待它们。这篇文章也可以提供帮助:Asynchronous programming with async and await .
关于c# - 应用程序在处理所有事件之前退出 - 基于事件的异步模式,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/59023105/
我目前正在为 Cocoa/Objective-C 项目编写一个脚本来完全自动化我的编译-运行-调试过程。 我的最后一行代码是: lldb -f Build/MyApp.app -o "run" 这实际
我有一个带有登录屏幕的脚本,如果按下取消按钮,我想完全退出该应用程序。我尝试了 3 种方法: 系统退出() QApplication.quit() QCoreApplication.instance(
我有一个 Flash 应用程序,可以重定向到另一个页面。我很乐意捕获任何其他窗口卸载事件(单击链接/提交表单)并警告用户他们将丢失 Flash 应用程序中的进度。 但是,我找不到任何方法来判断 URL
我正在尝试在 Ubuntu 上用 Python 编写一个简单的程序,它将在播放视频完成后关闭/退出/退出 VLC Player。 能否请您指导我应该在我的程序中添加什么以获得我需要的结果。 impor
我在 Lynda.com 上学习 PHP 2 视频时遇到了一个问题,因为讲师似乎忽略了告诉我们他在视频中执行的步骤之一。我在这里上传了相关视频http://www.youtube.com/watch?
某天在群内有同学问到,在python下我用input或者raw_input都得输入完后回车才能获取到输入的值,那如何实现任意键退出暂停等功能呢,我当时也没有多想,因为接触python时间也不算长,主
我按顺序调用了几个函数(我无法编辑),但有些函数会重定向用户,所以我永远不会进入下一个函数。 我正在调用一个第三方函数,它调用了我能够阻止的 wp_redirect(),但是下一行是 exit;我不知
终止/退出主函数的 D 方式是什么? import std.stdio; import core.thread; void main() { int i; while (i <= 5)
我正在申请写作。用户可以打开应用程序、写一些文本、保存他们的工作等。 我试图做到这一点,以便点击 window close按钮将提示用户 (a) 保存他们的工作(如有必要)或 (b) 退出。 我正在尝
我正在通过在 repl 中检查别人的代码来玩弄它。 它不断调用 System/exit,这导致我的 repl 崩溃。这真是令人气愤。 在我有权访问的所有代码中,我都模拟了调用。 但它也会调用一些我没有
我正在使用 subprocess执行mimic的模块程序(指定 here )。下面的代码成功地读取了一些文本并写入了一个 mp3 文件。 import subprocess proc = subpro
退出 .then 范围后数组上的值被清除 在下面的代码中tableValues1.length 给我正确的长度,直到它位于每个循环内当它退出时,作用域数组长度为零。 请谁能帮我解决这个问题 - 谢谢
我正在尝试为 s3cmd 编写一个 docker 镜像。当我通过 docker-compose 运行从 Dockerfile 构建的图像时,容器在 docker compose run 命令之前退出。
这个问题已经有答案了: 已关闭12 年前。 Possible Duplicate: Quitting an application - is that frowned upon? 我编写了一个 And
我遇到 Selenium WebDriver 仅执行一次后退出 for 循环的问题。据推测,这是获取内容和在加载页面之前启动循环的问题。是否有可能让 webdriver 等待页面加载? List al
#include #include #include #include "Player.h" using namespace std; void PlayerMenu(); int main()
class Test{ public static void main(String args[]) { Patron list[] = new PatronData(
我正在做一些作业,遇到了这个问题。 Write a program that reads several lines of text and prints a table indicating the
我正在用 C 创建一个简单的 Linux 命令 shell。我无法理解我的代码在哪里出现问题。 “commands”是我希望作为一个父进程的子进程同时执行的 Linux 命令字符串列表。当所有执行完成
我的控制台应用程序有点问题。应用程序应该从用户那里获取数字并将它们添加到列表中,但是如果输入是“c”,它应该关闭。我不知道如何在不使用 Scanner.nextLine() 挂起应用程序并退出循环的情
我是一名优秀的程序员,十分优秀!