【发布时间】: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