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() 行，它按预期完成工作，但当然最终会不时被阻止。 我做错了什么？

---

我可以直接在后台工作程序上实现等待，因为无论如何下载都足够快，但看起来设计仍然很糟糕，并且在慢速计算机上它会减慢太多。

有效但实现缓慢:

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)));
}

//....