Multi Threading, Thread läuft, ohne auf andere Threads zu warten

Question

Ich entwickle ein Programm, mit dem Sie mehrere XML-Dateien auswählen und an einen Webserver senden können.

Jede gesendete XML-Datei würde in einem Thread ausgeführt werden, sodass der Datenversand parallel ausgeführt wird. Das Problem, das ich habe, ist, dass wenn ich die erste Datei gebe, es früh antwortet, ohne sogar die nächsten paar Dateien einzugeben.

Ich weiß nicht, wie alle Threads warten, bis ich tippe, um zu beginnen, alle auf einmal auf einzelnen threads zu senden. Ich versuchte eine Implementierung unten, aber es reagiert zu früh, nachdem ich die erste Datei eingegeben habe.

Heres mein Code:

using System; 
using System.Collections.Generic; 
using System.IO; 
using System.Linq; 
using System.Net; 
using System.Text; 
using System.Threading; 
using System.Threading.Tasks; 
using System.Xml; 

namespace XMLSender 
{ 
    class Program 
    { 
     private static string serverUrl; 

     static void Main(string[] args) 
     { 
      Console.WriteLine("Please enter the URL to send the XML File"); 
      serverUrl = Console.ReadLine(); 
      List<Thread> threads = new List<Thread>(); 

      string fileName = ""; 
      do 
      { 
       Console.WriteLine("Please enter the XML File you Wish to send"); 
       fileName = Console.ReadLine(); 
       Thread t = new Thread(new ParameterizedThreadStart(send));    
       threads.Add(t); 
      } 
      while (fileName != "start"); //Ends if user enters an empty line 
      foreach (Thread t in threads) 
      { 
       t.Start(); 
      } 
      foreach (Thread t in threads) 
      { 
       t.Join(); 
      } 

     } 
     static private void send(object data) 
     { 
      try 
      { 
       //ServicePointManager.ServerCertificateValidationCallback = delegate { return true; }; 
       HttpWebRequest request = (HttpWebRequest)WebRequest.Create(serverUrl); 
       byte[] bytes; 

       //Load XML data from document 
       XmlDocument doc = new XmlDocument(); 
       doc.Load((string)data); 
       string xmlcontents = doc.InnerXml; 

       //Send XML data to Webserver 
       bytes = Encoding.ASCII.GetBytes(xmlcontents); 
       request.ContentType = "text/xml; encoding='utf-8'"; 
       request.ContentLength = bytes.Length; 
       request.Method = "POST"; 
       Stream requestStream = request.GetRequestStream(); 
       requestStream.Write(bytes, 0, bytes.Length); 
       requestStream.Close(); 

       // Get response from Webserver 
       HttpWebResponse response; 
       response = (HttpWebResponse)request.GetResponse(); 
       Stream responseStream = response.GetResponseStream(); 
       string responseStr = new StreamReader(responseStream).ReadToEnd(); 
       Console.Write(responseStr + Environment.NewLine); 

      } 
      catch (Exception e) 
      { 
       Console.WriteLine("An Error Occured" + Environment.NewLine + e); 
       Console.ReadLine(); 
      } 
     } 
    } 
} 

Answer 1

Wenn Sie auf einmal alle Themen starten wollen, in Ihrem do-while-Schleife, nicht noch die Fäden beginnen. (Dont rufen t.Start())

Stattdessen in der Zwischenzeit die Dateinamen in einer Liste speichern und dann, nach der while-Schleife, legen Sie eine weitere foreach-Schleife, die dann alle Fäden beginnt:

string fileName = ""; 
List<string> names = new List<string>(); 
do 
{ 
    Console.WriteLine("Please enter the XML File you Wish to send"); 
    fileName = Console.ReadLine(); 
    if(fileName != "start") 
    { 
     Thread t = new Thread(new ParameterizedThreadStart(send));    
     threads.Add(t); 
     names.Add(fileName); 
    } 
} 
while (fileName != "start"); 

foreach (Thread t in threads) 
{ 
    t.Start(names[0]); 
    names.RemoveAt(0); 
} 

Bearbeiten: Ich habe eine Überprüfung hinzugefügt, um sicherzustellen, dass Sie keinen weiteren Thread hinzufügen, wenn Sie start eingeben, da die Schleife immer noch beendet wird, auch wenn die Bedingung der Schleife nicht mehr wahr ist.
Ohne den Haken würde ein neuer Thread hinzugefügt werden das Ende mit start als Parameter hinzufügen.

Answer 2

Erstellen Sie zuerst eine ManulResetEvent. Dieses Ereignis kann dazu führen, dass Threads warten, bis ein bestimmtes Ereignis eintritt. Die ManulResetEvent wird dann ausgelöst, wenn alle Threads erlaubt sind, fortzufahren. Wie folgt aus:

class Program 
{ 
    private static readonly ManualResetEvent _wait = new ManualResetEvent(false); 
    ... 

In Ihrem Thread-Code, lassen Sie alle Threads warten:

static private void send(object data) 
{ 
    _wait.WaitOne(); 
    ... 

In Ihrem Main-Methode lösen das Ereignis nach alle Dateien eingeben:

... 
while (fileName != ""); //Ends if user enters an empty line 
_wait.Set() 
foreach (Thread t in threads) 
    ... 

Answer 3

Eine zweite Lösung könnte den Thread initialisieren, ohne sie zu starten, aber mit dem Dateinamen-Parameter:

... 
filename = Console.ReadLine(); 
Thread t = new Thread(() => send(filename)); 
threads.Add(t); 
... 

Und außerhalb der Schleife, starten Sie alle Fäden:

foreach (Thread t in threads) 
{ 
    t.Start(); 
}