如何在BackgroundWorker中启动线程

本文关键字：启动 线程 BackgroundWorker | 更新日期: 2023-09-27 18:25:39

我的应用程序必须连接到API并下载大约1200个项目。因为API的工作方式，我不能一次要求所有项目，我必须为每个项目发送一个查询。项目很小，所以下载很快，如果我在短时间内发送了太多请求（每2-3秒100个请求），服务器会阻止我（4-5秒）。我不希望服务器每次阻塞我的应用程序10-12次左右，所以我决定故意实现一个减速，另一个线程只需睡眠0.4秒，工作人员就会加入它，所以如果工作人员在0.4秒之前完成每次下载，它将等待，如果它在0.4秒之后完成，它将直接进入下一个

所需实施：

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

如何实现第一个选项？

如何在BackgroundWorker中启动线程

您的方法不起作用，因为正如文档所解释的：

一旦线程终止，就无法通过另一个对Start的调用来重新启动它。

因此，最简单的修复方法是每次重新创建线程：

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

然而，还不清楚你为什么要这么做。代码已经在另一个线程中运行了，所以你的第二种方法，使用Thread.Sleep似乎很好。你可以通过测量你是否真的需要等待整个时间来改进它（也许有些下载会持续更长的时间，所以没有必要总是等待400毫秒）。Stopwatch类是一个方便的类，可以用来测量时间块（与线程不同，它可以"重新启动"）。这个想法（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)));
}
//....
相关文章：