【问题标题】:C# Task Parallel Library first time slowC#任务并行库第一次慢
【发布时间】:2015-03-24 23:50:48
【问题描述】:

尝试并行执行多个 HTTP Get 请求,每个任务一个。如果我通过 Internet Explorer 执行 Gets,它们几乎会立即返回,但是当通过任务调用代码时,我第一次将它们关闭时,它们需要几秒钟才能返回,但第二次运行它们会按我的预期返回。所以要么我正在做一些阻塞某事的事情,或者由于某种原因线程没有启动?这是我第一次尝试使用 TPL。

这是基本的查找类:

public class Lookup
{
  public string Name { get; set; }
  public string URL { get; set; }

  public Lookup(string Name, string URL)
  {
    this.Name = Name;
    this.URL = URL;
  }

  public LookupReturn DoLookup()
  {
    LookupReturn d = new LookupReturn();
    d.Name = this.Name;
    d.URL = this.URL;

    WebRequest wrGETURL;
    wrGETURL = WebRequest.Create(this.URL);

    Stream objStream;
    objStream = wrGETURL.GetResponse().GetResponseStream();

    StreamReader objReader = new StreamReader(objStream);

    string sLine = objReader.ReadToEnd();
    d.Result = sLine;
    return d;
  }
}

而且返回类型很简单:

public class LookupReturn
{
  public string Name { get; set; }
  public string Result { get; set; }
  public string URL { get; set; }
}

因此尝试并行运行 - 我正在从 Winforms GUI 进行测试,但最终将在 WCF 服务中。

public partial class Form1 : Form
{
  private List<Lookup> Lookups = new List<Lookup>();

  private async void btnRunLookups_Click(object sender, EventArgs e)
  {
    Lookups.Add(new Lookup("Name1", "http://geturl1 "));
    Lookups.Add(new Lookup("Name2", "http://geturl2 ")); 
    // More lookups…  

    int workerThreads, complete;
    ThreadPool.GetMinThreads(out workerThreads, out complete);

    ThreadPool.SetMinThreads(100, complete);

    btnRunLookups.Visible = false;
    List <Task<LookupReturn>> lookupTasks = new List<Task<LookupReturn>>();
    foreach(Lookup dl in Lookups)
    {
      lbLookups.Items.Add("Starting task for " + dl.URL);

      Task<LookupReturn> t = new Task<LookupReturn>(() => dl.DoLookup() );
      lookupTasks.Add(t);
      t.Start();
    }

    //await Task.WhenAny(
    //  Task.WhenAll(lookupTasks.ToArray<Task<LookupReturn>>()), 
    //  Task.Delay(3000)
    //  );

    // This takes a good few seconds the first time
    await Task.WhenAll(lookupTasks.ToArray<Task<LookupReturn>>());

    // Now I need to see which ones completed and returned a result
    foreach (var x in lookupTasks)
    {
      if (x.IsCompleted)
      {
        lbLookups.Items.Add(x.Result);
      }
      else
      {
        // lbLookups.Items.Add("Not finished " + x.Result.Name);
      }
    }
    btnRunLookups.Visible = true;
  }

【问题讨论】:

  • 这行ThreadPool.SetMinThreads(100, complete); 做什么?来自 msdn “您可以使用 SetMinThreads 方法来增加最小线程数。但是,不必要地增加这些值可能会导致性能问题。如果同时启动的任务太多,它们可能看起来都很慢。在大多数情况下,线程池使用自己的线程分配算法会表现得更好。将最小值减少到小于处理器数量也会损害性能。”
  • 当你说第一次比第二次花费更长的时间时,你是不是分别运行了两次程序?还是您启动程序并执行两次查找代码?
  • SetMinThreads 我在其他地方读到的,如果您需要的线程数多于内核数,它会很有帮助 - 取出它没有区别。
  • 启动程序并运行两次查找。

标签: c# multithreading winforms task-parallel-library


【解决方案1】:

Other people 注意到HttpWebRequest 在其第一个请求上可能需要很长时间,因为它正在寻找代理信息。尝试将其 Proxy 属性设置为 null。

wrGETURL = WebRequest.Create(this.URL);
wrGETURL.Proxy = null;

【讨论】:

    【解决方案2】:

    问题很可能是程序在第一次调用GetResponse 时进行了一些首次设置(DNS 解析、代理检测等)。尤其是代理检测,可能需要很长时间。

    【讨论】:

      猜你喜欢
      • 2018-06-02
      • 1970-01-01
      • 1970-01-01
      • 2012-02-17
      • 2019-03-09
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      相关资源
      最近更新 更多