c# - 如何在 BackgroundWorker 中启动线程？

Question

我的应用程序必须连接到 API 并下载大约 1200 个项目。由于 API 的工作方式，我无法一次请求所有项目，我必须为每个项目发送一个查询。项目很小，所以下载很快，如果我在短时间内发送太多请求(每 2-3 秒 100 个请求)，服务器会阻止我(4-5 秒)。我不希望服务器每次阻塞我的应用程序大约 10-12 次，所以我决定有意实现减速，另一个线程只休眠 0.4 秒，工作人员将加入它，所以如果工作人员完成每个在0.4s标记之前下载会等待，如果晚完成则直接进行下一步

期望的实现:

private void DownloadLibrary_DoWork(object sender, DoWorkEventArgs e)
{
    int max = 1200;
    int slowdown = 400; // milliseconds

    Thread methronome = new Thread(() => Thread.Sleep(slowdown));

    for (int i = 0; i < max; i++)
    {
        methronome.Start();

        DownloadItem(i);            
        WorkerDownloadLibrary.ReportProgress((int)i / max, string.Format("Dowloaded item {0} out of {1}", i+1, max));

        methronome.Join();
    }
}

private void UserClickStart(object sender, RoutedEventArgs e)
{
    System.Windows.MessageBox.Show("Let's start!");
    WorkerDownloadLibrary.RunWorkerAsync();
}

private void DownloadLibrary_RunWorkerCompleted(object sender, RunWorkerCompletedEventArgs e)
{ 
    System.Windows.MessageBox.Show("Completed!"); 
}

问题是，如果我这样做，后台工作程序会提前结束(RunWorkerCompleted 执行)，如果我同时注释 methronome.Start() 和 methronome.Join() 行，它按预期工作，但当然最终会不时被阻止。 我做错了什么？

---

我可以直接在 backgroundworker 上实现等待，因为无论如何下载速度都足够快，但设计仍然很糟糕，而且在慢速计算机上它会减慢太多。

工作但实现缓慢:

private void DownloadLibrary_DoWork(object sender, DoWorkEventArgs e)
{
    int max = 1200;
    int slowdown = 400; // milliseconds

    for (int i = 0; i < max; i++)
    {
        DownloadItem(i);            
        WorkerDownloadLibrary.ReportProgress((int)i / max, string.Format("Dowloaded item {0} out of {1}", i+1, max));
        Thread.Sleep(slowdown);
    }
}

---

还有另一种方法:一个接一个地发送所有查询，只有在服务器阻塞时才等待，但设计似乎很糟糕，每 2 秒停止一次下载时用户会挠头。如果我总是这样做，服务器可能会永久阻止我

工作但明显糟糕的实现

private void DownloadLibrary_DoWork(object sender, DoWorkEventArgs e)
{
    int max = 1200;
    int slowdown = 5000; // milliseconds

    string serverResponse;
    for (int i = 0; i < max; i++)
    {
        do
        {
            serverResponse = DownloadItem(i);

            if (serverResponse != "OK")
                Thread.Sleep(slowdown);

        } while (serverResponse != "OK") ;

        WorkerDownloadLibrary.ReportProgress((int)i / max, string.Format("Dowloaded item {0} out of {1}", i+1, max));
    }
}

如何实现第一个选项？

Answer 1

您的方法无效，因为 as the documentation explains :

Once the thread terminates, it cannot be restarted with another call to Start.

因此，最简单的解决方法是每次都重新创建线程:

for (int i = 0; i < max; i++)
{
    Thread methronome = new Thread(() => Thread.Sleep(slowdown));
    methronome.Start();

   //..

但是，尚不清楚您为什么要这样做。该代码已经在另一个线程中运行，因此您使用 Thread.Sleep 的第二种方法似乎不错。您可以通过测量是否真的需要等待全部时间来改进它(也许某些下载持续时间更长，因此无需始终等待全部 400 毫秒)。 Stopwatch 是一个方便的类，可用于测量时间 block (并且与线程不同，可以“重新启动”)。类(class)。这个想法(也由 jessehouwing 在评论中发表)看起来像这样:

int max = 1200;
int slowdownMs = 400;
Stopwatch sw = new Stopwatch();

for (int i = 0;i < max; ++i)
{
    sw.Restart();

    DownloadItem(i);    
    ReportProgress(i, max);        

    sw.Stop();

    Thread.Sleep(Math.Max(0, (int)(slowdownMs - sw.ElapsedMilliseconds)));
}

//....