后台工作人员行为异常

Question

我正在编写一些调用服务的代码。此服务调用可能会失败，如果确实如此，我希望系统重试，直到它正常工作或已经过去了太多时间。

我想知道我哪里出了问题，因为以下代码似乎无法正常工作...它随机只执行一到四个循环...

protected virtual void ProcessAsync(object data, int count)
{
    var worker = new BackgroundWorker();
    worker.DoWork += (sender, e) =>
    {
        throw new InvalidOperationException("oh shiznit!");
    };
    worker.RunWorkerCompleted += (sender, e) =>
    {
        //If an error occurs we need to tell the data about it
        if (e.Error != null)
        {
            count++;
            System.Threading.Thread.Sleep(count * 5000);
            if (count <= 10)
            {
                if (count % 5 == 0)
                    this.Logger.Fatal("LOAD ERROR - The system can't load any data", e.Error);
                else
                    this.Logger.Error("LOAD ERROR - The system can't load any data", e.Error);
                this.ProcessAsync(data, count);
            }
        }
    };
    worker.RunWorkerAsync();
}

干杯 安东尼

更新：

我已经将代码切换为使用 ThreadPool.QueueUserWorkItem 来代替...自从这样做以来，我的问题就消失了，从语义上讲我可以做同样的事情。感谢你们所有的帮助。

Answer 1

我稍微修改了您的代码，并且在 10 次迭代（VS 2008 Express）中没有遇到任何问题，这使我想到：这是实际代码吗？如果不是，您确定吗？已发送足够的信息来重现该问题？

如果我大胆猜测，我会说您发送的计数会有所不同，例如 count % 5 > > 0 并且在 Logger.Fatal 中抛出异常。

private void button1_Click(object sender, EventArgs e)
{
    ProcessAsync("beer", 1);
}

protected virtual void ProcessAsync(object data, int count)
{
    var worker = new BackgroundWorker();
    worker.DoWork += (sender, e) =>
    {
        throw new InvalidOperationException("oh shiznit!");
    };
    worker.RunWorkerCompleted += (sender, e) =>
    {
        //If an error occurs we need to tell the data about it
        if (e.Error != null)
        {
            count++;
            //System.Threading.Thread.Sleep(count * 5000);
            if (count <= 10)
            {
                if (count % 5 == 0)
                    this.Logger.Fatal("LOAD ERROR - The system can't load any data - " + count.ToString(), e.Error);
                else
                    this.Logger.Error("LOAD ERROR - The system can't load any data - " + count.ToString(), e.Error);
                this.ProcessAsync(data, count);
            }
        }
    };
    worker.RunWorkerAsync();
}

SomeLogger Logger = new SomeLogger();

class SomeLogger
{
    public void Fatal(string s, Exception e)
    {
        System.Diagnostics.Debug.WriteLine(s);
    }

    public void Error(string s, Exception e)
    {
        System.Diagnostics.Debug.WriteLine(s);
    }
}

编辑：建议
在对 Logger.Fatal 的调用周围放置一个 try-catch 并看看会发生什么。

编辑：另一个建议
我怀疑您没有分享足够的代码来帮助我们。这里成功的关键是将问题隔离在一个只有足够代码来显示失败的虚拟项目中。我愿意打赌，如果你能做到这一点，你很可能不需要将其作为问题发布在这里......

你可以从我的假设开始，并且应该看到这工作得很好。然后开始将通用代码更改为您实际使用的代码（我将从 Logger.Fatal 的实际实现开始）。该错误可能会在短时间内变得非常明显。

Answer 2

这一定是我见过的最奇怪的重试机制了。你能做一个更干净的吗？避免递归调用，除非它们简单且易于维护，因为它很容易导致错误。

Answer 3

我没有看到明显的原因。但是，您的 RunWorkerCompleted 事件通常会在 UI 线程上运行。并悬挂长达55秒。那是不可取的。

我无法想象为什么您不使用 try/catch 块在 DoWork 方法中循环。

Answer 4

有件事真的糟糕！

在 RunWorkerCompleted() 中，您调用 Thread.Sleep()。事实上，该函数将在 GUI 线程中处理，您的应用程序将冻结！

请不要在BackgroundWorker 的任何事件中调用Thread.Sleep()，因为所有这些事件都将在GUI 线程内处理。

因此，这可能不是您当前问题的真正解决方案，但绝对是您应该关心的事情。

更新
要在给定时间段后开始某些操作，您应该查看 各种 计时器 < a href="http://msdn.microsoft.com/en-us/library/system.threading.timer.aspx" rel="nofollow noreferrer">类。他们每个人都有自己的优点和缺点。要获得更深入的了解，您应该查看这篇文章。