c# - winforms:使用 parallel.foreach 更新进度
问题描述
我没有看到任何与我的问题有关的帖子,所以如果我发布了一个已经提出的问题,我深表歉意。
我有一个 Windows 窗体程序 c#,它可以检查股票并进行分析。主窗体通过新线程和 ShowDialog 启动另一个窗体。在加载时,它正在运行一个 parallel.foreach。在那个parallel.foreach 中,我想在主窗体上显示进度。
我遇到了跨线程问题,并添加了调用,尽管它似乎不是线程安全的,因为它似乎在 parallel.foreach 结束时死锁。我试过代表,事件,没有运气。帮帮我欧比旺,你是我唯一的希望!
精简版:
主要形式
private void button1_Click(object sender, EventArgs e)
{
YearLows yearLows = new YearLows();
Thread yearLowsThread = new Thread(() => StartYearLows(yearLows));
yearLowsThread.Start();
btnGetYearLows.Enabled = false;
}
private void StartYearLows(YearLows yearLows)
{
yearLows.ShowDialog();
}
public void UpdateProgress(string text)
{
lblProgress.Text = text;
}
第二种形式对话框
public partial class YearLows : Form
{
private void YearLows_Load(object sender, EventArgs e)
{
// work
Parallel.ForEach(responseStocks, new ParallelOptions { MaxDegreeOfParallelism = MaxThreads }, x =>
{
// more work
Interlocked.Increment(stocksProcessed);
UpdateProgress($"{stocksProcessed} / {stocksTotal} Researched");
});
}
private void UpdateProgress(string text)
{
Invoke(new Action(() => frmMain.UpdateProgress(text)));
}
}
更新 1:如果我将进度更新标签移动到子表单,我似乎正在获取所有进度更新。我必须从 Load 事件转移到 Shown 事件,以便呈现表单,以便用户可以看到进度更新。不过,我必须遵循 SLaks 的建议并运行 Task.Run(() => Parallel.ForEach。这对我有用。如果我想要主进度更新,我仍然想弄清楚为什么它仍然会锁定到最后(我一直读到 async void 很糟糕,但我想在 winforms 中这些定义的方法签名中没有办法解决这个问题)
public partial class YearLows : Form
{
private async void YearLows_Shown(object sender, EventArgs e)
{
await AnalyzeStocks();
}
private async Task AnalyzeStocks(object sender, EventArgs e)
{
// work
await Task.Run(() => Parallel.ForEach(responseStocks, new ParallelOptions { MaxDegreeOfParallelism = MaxThreads }, x =>
{
// more work
Interlocked.Increment(stocksProcessed);
UpdateProgress($"{stocksProcessed} / {stocksTotal} Researched");
}));
}
private void UpdateProgress(string text)
{
Invoke(new Action(() => lblProgress.UpdateProgress(text)));
}
}
解决方案
Parallel.ForEach
是阻塞调用;它也在调用线程上运行委托。因此,UI 在完成之前无法更新。
相反,您应该使用await
with Task.WhenAll
(如果您正在执行异步工作)或Task.Run(() => Parallel.ForEach(...))
(如果它受 CPU 限制),以便您让 UI 线程空闲并能够更新。
推荐阅读
- react-native - 在 React Native 中将项目定位在屏幕底部
- postgresql - 在 postgresql 中创建规则以在 INSERT 上自动添加 json
- macos - kubernete 服务被阻塞/在 mac 中使用 minikube 加载
- tensorflow - 神经网络训练的封面图
- android - 如何在按钮android中使用文本设置drawable
- javascript - 将一个迭代器转换为另一个迭代器
- python - 不断接收来自 Azure ServiceBus 的消息
- java - AMQP 重新投递政策
- angular - 使用 AngularFireStore 将文档/集合作为对象返回
- html - 将导航栏的元素放在最左侧,而其他元素居中