HttpWebRequest - kann ich mehrere Anrufe bei der sametime von mehreren threads

Um ehrlich zu sein, ich glaube nicht, dass die multi-threading, den Sie versuchen zu tun, ist zu bekommen Sie irgendwelche performance-Gewinne. Und zu sehen, dass es keine Schwelle für die Anzahl der threads, die Sie könnte die Schaffung hier das Potenzial für eine schlechtere Leistung als ein single-threaded (sequenziellen) Vorgang existiert.

Die ideale situation ist, dass Sie eine asynchrone Arbeitsabläufe. wo die Schleife ist so etwas wie dieses:

GetAsyncRequest
MakeAsyncRequest
ReceiveResponseAsync
ProcessResponse
WaitForAllRequestProcessingToComplete(Optional)

So, dass das Ergebnis jeder Schritt fließt in die nächste (falls es eine Folge) und die nächste. Und Sie sind der Verarbeitung der Antworten so bald, wie Sie Sie erhalten anstatt akkumulieren (Eintritt/blockieren) alle Antworten, bevor Sie Sie verarbeiten. Diese Art der Sache kann leicht getan werden mit Aufgaben und ContinueWith-in .NET 4.0 und sehen, dass Sie habe mit .NET 4.0, ich würde empfehlen Ihnen dringend, tun Sie es wie oben beschrieben.

Aber, wenn Sie nicht konvertieren Sie Ihre Bearbeitung in einem asynchronen workflow, dann...

Die Methode, die unten gezeigt wird, ist die Methode, die den Aufruf aus, um die Url und gibt eine Antwort zurück. Die Methode verwendet Asynchrone Aufrufe aber blockiert, da Ihr design zu sein scheint, als solche.

static string GetWebResponse(string url, NameValueCollection parameters)
{
  var httpWebRequest = (HttpWebRequest)WebRequest.Create(url);
  httpWebRequest.ContentType = "application/x-www-form-urlencoded";
  httpWebRequest.Method = "POST";

  var sb = new StringBuilder();
  foreach (var key in parameters.AllKeys)
    sb.Append(key + "=" + parameters[key] + "&");
  sb.Length = sb.Length - 1;

  byte[] requestBytes = Encoding.UTF8.GetBytes(sb.ToString());
  httpWebRequest.ContentLength = requestBytes.Length;

  using (var requestStream = httpWebRequest.GetRequestStream())
  {
    requestStream.Write(requestBytes, 0, requestBytes.Length);
    requestStream.Close();
  }

  Task<WebResponse> responseTask = Task.Factory.FromAsync<WebResponse>(httpWebRequest.BeginGetResponse, httpWebRequest.EndGetResponse, null);
  using (var responseStream = responseTask.Result.GetResponseStream())
  {
    var reader = new StreamReader(responseStream);
    return reader.ReadToEnd();
  }
}

Würden Sie es so nennen:

  ServicePointManager.DefaultConnectionLimit = 20;//Please test different numbers here
  var tasks = new List<Task<string>>();
  for (int i = 1990; i < 2090; i++)
  {
    var postParameters = new NameValueCollection();
    postParameters.Add("data", i.ToString());
    tasks.Add(Task.Factory.StartNew(() => { return GetWebResponse("http://www.abc123.com", postParameters); }));
  }
  Task.WaitAll(tasks.ToArray());
  //At this point tasks[0].Result will be the result (The Response) of the first task
  //tasks[1].Result will be the result of the second task and so on.

Sehen, ob das funktioniert für Sie.

Wenn Sie wirklich brauchen, multi-Threading-Fähigkeit, natürlich zu sehen, dass Sie schlagen nur eine Seite hat, müsste man zur Messung der performance-Vorteile, da der Standort muss in der Lage sein zu handhaben, den Ansturm der Anfragen und der Kunde die Kosten der Erstellung von threads, nur für einige I/O-gebundene Aufgabe könnte am Ende wird zu teuer und am Ende keine performance-Gewinne.

Außerdem ohne Anpassung der DefaultConnectionLimit in der ServicePointManager, du wirst nie mehr als 2 threads entweder Möglichkeiten, da wirst du gegen eine domain und der Standardwert ist 2 threads pro domain.

Würd ich mich mit dem code, den ich hier vorgestellt habe und wenn es ein performance-problem nur dann würde ich schauen, tun es auf eine andere Weise.

Edit:
bei der Verwendung von Async-I/O-Sie sind nicht mit worker-threads, aber I/O-thread. Also im Grunde, die Sie nicht verwenden möchten QueueUserWorkItem (, threads zu erstellen), oder Sie sind nicht schaffen threads selbst.

Den code, den ich hier vorgestellt habe ist die Verwendung von Async-I/O-und wenn man auf ausführen mehrerer Anfragen simutaneously und so schnell wie möglich.

Die for-Schleife (in der zweiten code-listing) wird die Oberfläche fast sofort, obwohl in der Beispiel-loops für 100 Iterationen, und dann warten Sie, bis alle I/O-Anfragen zu beenden. Der ThreadPool-und OS-Griff-Ausführung des I/O-Aufträge, sobald und so schnell wie möglich. In der Tat, denn diese jobs sind I/O gebunden sind, werden Sie nicht sehen, Ihre CPU-Auslastung gehen, bis Sie entweder (es sei denn, man tut der cpu bestimmt die spätere Arbeit).

Nur spielen, mit der Dienste-Verwalter.DefaultConnectionLimit, um mehr Beschleunigung, wenn nötig. Beachten Sie, dass dies wirkt sich auf den service (der server) als auch, weil, wenn Sie machen eine Menge von gleichzeitigen Anfragen, die der server, die Sie aufrufen wird stark belastet und das kann nicht etwas sein, was Sie wollen. Es ist also eine balance, die Sie benötigen, zu streiken.

Nach dem Aufruf von Task.WaitAll, können Sie Durchlaufen Ihre Aufgaben Sammlung und erhalten Sie die Ergebnisse der einzelnen Aufgabe mit der syntax gezeigt, in die auskommentierte Zeile in der code-Auflistung.