- c - 在位数组中找到第一个零
- linux - Unix 显示有关匹配两种模式之一的文件的信息
- 正则表达式替换多个文件
- linux - 隐藏来自 xtrace 的命令
我正在尝试弄清楚如何使用 Task 类。过去我一直使用常规的 Thread 类,但我试图掌握所有异步编程...
例如,我创建了一个包含所有代码的主 Winforms 应用程序。我的问题的相关代码是:
//Relevant delegates
public delegate void MethodAction(int num);
public delegate void MethodConversion();
public delegate void OnCompletionAction(string completiontext);
//Button user presses
private void button4_Click(object sender, EventArgs e)
{
richTextBox1.Clear();
sw.Reset();
sw.Start();
Sync.RunAsync3(calcSim);
}
//The method that simulates a calculation by adding a sleep
//the input param threadlength is just to allow threads to take longer than others
//since I'm multithreading, I have to invoke the writing code on the windows RichTextbox control
private void calcSim(int threadlength)
{
string threadname = Thread.CurrentThread.Name;
for (int i = 0; i < 10; i++) //Thread calc should take 3s
{
Thread.Sleep(300 + threadlength);
richTextBox1.Invoke((MethodConversion)(() =>
{
richTextBox1.AppendText(string.Format("Thread: {0}\tVersion: {1}\n", threadname, (i + 1).ToString()));
}));
}
}
//Class that contains the different processing methods
public static class Sync
{
public static event OnCompletionAction OnProcCompletion;
public static void RunAsync3(MethodAction doM)
{
Task[] t = new Task[4];
for(int i = 0; i < 4; i++)
{
t[i] = Task.Factory.StartNew((Action)(() => { doM(50 * i); }));
}
Task.WaitAll(t);
if (OnProcCompletion != null) OnProcCompletion("RunSync method finished");
}
}
问题出在 Task.WaitAll(t)... 由于某种我无法弄清楚的原因,它完全阻塞在那条线上并且不再响应。如果我省略该行,表单会实时更新,执行大约需要 3 秒。
我的问题是:为什么 Task.WaitAll() 不在释放 UI 线程并允许其余代码执行之前阻塞 UI 线程 3 秒?
我知道它应该会阻塞 UI 一段时间(直到计算完所有线程),但它会无休止地阻塞整个应用程序。好像要等到永远?
编辑
有人建议我使用 WhenAll 而不是 WaitAll。我重写了 RunAsync3 如下:
public static void RunAsync3(MethodAction doM)
{
Task[] t = new Task[4];
for(int i = 0; i < 4; i++)
{
t[i] = Task.Factory.StartNew((Action)(() => { doM(50 * i); }));
}
//Task.WaitAll(t); -> deadlock
Task.WaitAll(new Task [] { Task.WhenAll(t) });
if (OnProcCompletion != null) OnProcCompletion("RunSync method finished");
}
但这仍然陷入僵局......?我可能没有正确使用 WhenAll?
编辑 2
因为每个人都声称我阻塞了 UI 线程是正确的,所以我决定尝试另一种方式:通过在 UI 线程内运行一个新线程作为我的调用线程(这样阻塞现在会发生在我的线程上而不是 UI线)。这行得通,但显然不是最好的方法!
private void button4_Click(object sender, EventArgs e)
{
Thread t = new Thread(new ThreadStart(() =>
{
richTextBox1.Invoke((MethodConversion)(() => richTextBox1.Clear()));
sw.Reset();
sw.Start();
Sync.RunAsync3(calcSim);
}));
t.Start();
}
public static void RunAsync3(MethodAction doM)
{
Task[] t = new Task[4];
for(int i = 0; i < 4; i++)
{
t[i] = Task.Factory.StartNew((Action)(() => { doM(50 * i); }));
}
Task.WaitAll(t);
//Task.WaitAll(new Task [] { Task.WhenAll(t) });
if (OnProcCompletion != null) OnProcCompletion("RunSync method finished");
}
最佳答案
你造成了僵局。
UI 线程正在等待 4 个任务完成。
另一方面,这 4 个运行 calcSim
的任务正在尝试调用 UI 线程上的代码 -> 死锁。
您应该改用 Task.WhenAll()
。该方法将返回一个新任务,当您的所有任务完成后,该任务将被标记为已完成。如果您等待该任务,您的 UI 线程将被释放,因此 calcSim
将能够在 UI 线程上调用代码,避免死锁。
更新
你用错了。您仍在使用 WaitAll
,这是一个阻塞调用。您应该将其替换为WhenAll
。
await Task.WhenAll(t);
来自documentation :
Creates a task that will complete when all of the supplied tasks have completed.
通过对结果调用 await
,您的 UI 线程将空闲 - 直到所有 4 个任务完成。发生这种情况时,您的 RunAsync3
方法将恢复。
关于c# - Task.WaitAll() 没有按预期工作,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/19766535/
我听说在多个线程上使用 waitall 时存在限制(要等待的线程数?)。谁能给详细点? 最佳答案 我认为你所指的限制不是线程的数量;它取决于正在等待的句柄 的数量。来自MSDN page对于 Wait
假设我正在编写一个模拟用户在系统上执行某些操作的软件。我正在使用秒表测量完成此类操作所需的时间。 大多数时候这是非常简单的:模拟按钮的点击,一些服务调用与这个按钮相关联。测量完成此服务调用所需的时间。
当我可以让父任务等待它创建的所有任务时,我不确定创建子任务有什么好处。我运行以下代码,它在两种情况下产生了相同的结果。 public static void Main(string[] args) {
我有这样的情况: var retrievalTasks = new Task[2]; retrievalTasks[0] = GetNodesAsync(); retrievalTasks[1] =
我有少量任务,我想使用 Task.WaitAll 并行运行它们。这是我现在拥有的: type System.Threading.Tasks.Task with static member Wait
我有一个关于 Task.WaitAll 的问题。起初我尝试使用 async/await 来得到这样的东西: private async Task ReadImagesAsync(string HTML
我有一个控制台应用程序,我需要在其中从 4 个不同的站点检索一些数据。我将每个 HTTP 请求放在一个任务中,然后等待它们全部完成。 当我只需要从 2 个站点获取数据时,它就可以正常工作。但后来我需要
是否有可能不使用 WaitHandle.WaitAll(waitHandles) 阻止 winForm,而是设置另一个线程,当从 WaitHandle.WaitAll 获取完成信号时将触发该线程? 最
我想同时运行两个任务,其中一个任务中有一个 Task.Delay()。 即一个连续运行,一个每 15 分钟运行一次。 这是我目前所拥有的: public class ContinousAndAggre
为什么这不是每次都完成?相反,它会抛出一个异常,就像没有捕获到异常一样。此外,异常“索引超出数组范围”对我来说没有意义。 int n = 3; string[] nam
我正在尝试使用此异步代码来测试异步关键字: public async Task AsyncMethod() { var link = "http://www.google.com";
我有两个 ContinueWith 用于一个任务。第一个处理任务成功完成的情况,第二个处理任务失败的情况。然后我等到其中一个完成。示例代码如下: var task = Task.Factory.Sta
我正在使用我的可移植类库异步检索一些 rss 文章,该类库使用 Microsoft.Bcl 库(没有 Task.WhenAll)。每篇文章都有一个 rss 评论的 url,我也需要异步检索它。 下面的
我的目标是从 Amazon Web Services 存储桶下载图像。 我有以下代码功能,可以一次下载多张图片: public static void DownloadFilesFromAWS(str
我的代码中有这样一种情况,我开始执行未知数量的任务并想使用 Task.WaitAll()。 像这样: if (condition) { var task1 = Task.Factory.Sta
我创建了一个 Task 列表,如下所示: public void A() { } public void B() { } public void C() { } public void Ex() {
使用 System.Threading.Tasks.Task.WaitAll() 我可以看到我应该使用此方法的可用参数 可见here但是在 visual studio 中编写时,我可以调用完全没有参数
WaitAll 不工作。我在任务完成之前得到完成。 我有一些群组。每个组都包含项目,我希望每个项目在单独的任务中处理。 static void Main(string[] args) { Li
更新以更清楚地解释事情 我有一个运行多个任务的应用程序。有些是最初创建的,有些可以稍后添加。我需要一个编程结构来等待所有任务完成。一旦所有任务完成,应该运行一些其他代码来清理事情并对其他任务生成的数据
就并行性而言,这些是等价的吗? async Task TestMethod1() { Task t1 = GetInt1(); Task t2 = GetInt2(); awa
我是一名优秀的程序员,十分优秀!