C# 对“即发即弃”的改进

发布于 2024-08-26 21:50:41 字数 553 浏览 5 评论 0原文

我有一个程序

，它创建一个类的多个实例，在所有实例上运行相同的长时间运行的 Update 方法并等待完成。我正在遵循这个问题<的Kev方法< /a> 将更新添加到 ThreadPool.QueueUserWorkItem。

在主程序中，我睡了几分钟，然后检查最后一个孩子的布尔值，看看是否完成。

while(!child[child.Length-1].isFinished) {
    Thread.Sleep(...);
}

这个解决方案正在按照我想要的方式工作，但是有没有更好的方法来做到这一点？既适用于独立实例，也适用于检查所有工作是否已完成。

谢谢

更新： 不需要加锁。每个不同的实例都有一个不同的 Web 服务 URL，它们从中请求，并对响应执行类似的工作。他们都在做自己的事情。

原文

Greetings

I have a program that creates multiples instances of a class, runs the same long-running Update method on all instances and waits for completion. I'm following Kev's approach from this question of adding the Update to ThreadPool.QueueUserWorkItem.

In the main prog., I'm sleeping for a few minutes and checking a Boolean in the last child to see if done

while(!child[child.Length-1].isFinished) {
    Thread.Sleep(...);
}

This solution is working the way I want, but is there a better way to do this? Both for the independent instances and checking if all work is done.

Thanks

UPDATE:
There doesn't need to be locking. The different instances each have a different web service url they request from, and do similar work on the response. They're all doing their own thing.

分享到QQ

分享到微博

如果你对这篇内容有疑问，欢迎到本站社区发帖提问参与讨论，获取更多帮助，或者扫码二维码加入 Web 技术交流群。

发布评论

需要登录才能够评论，你可以免费注册一个本站的账号。

面犯桃花 2024-09-02 21:50:41

如果您知道将执行的操作数，请使用倒计时和事件：

Activity[] activities = GetActivities();
int remaining = activities.Length;
using (ManualResetEvent finishedEvent = new ManualResetEvent(false))
{
    foreach (Activity activity in activities)
    {
        ThreadPool.QueueUserWorkItem(s =>
        {
            activity.Run();
            if (Interlocked.Decrement(ref remaining) == 0)
                finishedEvent.Set();
        });
    }
    finishedEvent.WaitOne();
}

不要轮询完成情况。 .NET Framework（以及一般的 Windows 操作系统）具有许多专门设计用于防止对自旋锁的需求的线程原语，并且具有 Sleep 的轮询循环实际上只是慢速自旋锁。

If you know the number of operations that will be performed, use a countdown and an event:

Activity[] activities = GetActivities();
int remaining = activities.Length;
using (ManualResetEvent finishedEvent = new ManualResetEvent(false))
{
    foreach (Activity activity in activities)
    {
        ThreadPool.QueueUserWorkItem(s =>
        {
            activity.Run();
            if (Interlocked.Decrement(ref remaining) == 0)
                finishedEvent.Set();
        });
    }
    finishedEvent.WaitOne();
}

Don't poll for completion. The .NET Framework (and the Windows OS in general) has a number of threading primitives specifically designed to prevent the need for spinlocks, and a polling loop with Sleep is really just a slow spinlock.

回复收藏 0 原文