Using Threads namespace in .net framework we can trigger the concurrent HTTP requests to server. True concurrency can be achieved only when there is more than 1 CPU otherwise it's only a virtual thing that is achieved using swtiching b/w each threads by a single CPU.
A different note about Threading: Threading is useful only when the operation task involved in the threading method is I/O bound or wait for other resources involved. If it's only computational then Threading leverage no advantage & can backfire since there is cost for context switching b/w each threads.
A different note about Threading: Threading is useful only when the operation task involved in the threading method is I/O bound or wait for other resources involved. If it's only computational then Threading leverage no advantage & can backfire since there is cost for context switching b/w each threads.
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 | static void Main(string[] args) {<thread><thread>while (true) { List<Thread> lstThreads = new List<Thread>(); /* Thread objThread1 = new Thread(new ParameterizedThreadStart(DeadLockWithHotelDescriptiveContentNotifRQUpdate)); lstThreads.Add(objThread1); Thread objThread2 = new Thread(new ParameterizedThreadStart(DeadLockWithHotelDescriptiveContentNotifRQUpdate)); lstThreads.Add(objThread2); Thread objThread3 = new Thread(new ParameterizedThreadStart(DeadLockWithHotelDescriptiveContentNotifRQUpdate)); lstThreads.Add(objThread3); Thread objThread4 = new Thread(new ParameterizedThreadStart(DeadLockWithHotelDescriptiveContentNotifRQUpdate)); lstThreads.Add(objThread4); string fileLocation = @"D:\Asif\JIRA\NEO\Interface Migration\Sprint14\NEORND-3630\Meera\DAO Error\xml4DCRQ.xml"; objThread1.Start(File.ReadAllText(string.Format("{0}\\{1}", fileLocation, "RTAV_Local_Series1.xml"))); objThread2.Start(File.ReadAllText(string.Format("{0}\\{1}", fileLocation, "RTAV_Local_Series2.xml"))); objThread3.Start(File.ReadAllText(string.Format("{0}\\{1}", fileLocation, "RTAV_Local_Series3.xml"))); objThread4.Start(File.ReadAllText(string.Format("{0}\\{1}", fileLocation, "RTAV_Local_Series4.xml"))); */ string fileLocation = @"D:\JIRA\NEO\Sundarbans\Sprint20\NEORND-7568 [Search Connector] Load test optimized codebase\AvailRQMultiPropertySearchRQ.xml"; for (int i = 1; i <= 30; i++) { Thread objThread = new Thread(new ParameterizedThreadStart(DeadLockWithHotelDescriptiveContentNotifRQUpdate)); lstThreads.Add(objThread); objThread.Start(File.ReadAllText(fileLocation)); } int ctr = 1; foreach (var thread in lstThreads) { thread.Join(); if (ctr == lstThreads.Count) { Console.WriteLine("All HDC threads finished executing"); goto EndWhile; } ctr++; } } EndWhile: Console.WriteLine("Press Any key to exit"); Console.ReadLine();}static void DeadLockWithHotelDescriptiveContentNotifRQUpdate(object payload) { string xmlPayload = (string)payload; string response_text = string.Empty; try { System.Net.ServicePointManager.SecurityProtocol = SecurityProtocolType.Tls12; System.Net.ServicePointManager.ServerCertificateValidationCallback += ValidateRemoteCertificate; //string url = "https://hotfix.hbsconnect.com/app/dm/xml/xml4test"; //string url = "http://localhost/app/dm/xml/xml4test"; HttpWebRequest request = (HttpWebRequest)System.Net.WebRequest.Create(url); //-------GETTING WEBPROXY OF LOCAL MACHINE==========// WebProxy proxy = (WebProxy)WebProxy.GetDefaultProxy(); if (proxy.Address != null) { proxy.Credentials = System.Net.CredentialCache.DefaultNetworkCredentials; WebRequest.DefaultWebProxy = new System.Net.WebProxy(proxy.Address, proxy.BypassProxyOnLocal, proxy.BypassList, proxy.Credentials); } //request.Proxy = proxy; //----PROXY SET UP===========// byte[] bytes = Encoding.UTF8.GetBytes(xmlPayload); request.Method = "POST"; request.Accept = "*/*"; request.Timeout = 360000; //=6mnts request.ContentType = "text/xml"; // text/plain request.KeepAlive = false; request.ContentLength = bytes.Length; request.ProtocolVersion = HttpVersion.Version10; //request.ServicePoint.Expect100Continue = true; Stream stream = request.GetRequestStream(); stream.Write(bytes, 0, bytes.Length); stream.Flush(); using (HttpWebResponse response = (HttpWebResponse)request.GetResponse()) { /* Stream responseStream = response.GetResponseStream(); StreamReader Reader = new StreamReader(responseStream, Encoding.Default); response_text = Reader.ReadToEnd(); */ Stream response_stream = response.GetResponseStream(); byte[] byteStream = new byte[512]; StringBuilder sbResponse = new StringBuilder(); System.Text.Encoding utfEncode = System.Text.Encoding.GetEncoding("utf-8"); int byteCount = response_stream.Read(byteStream, 0, 512); while (byteCount > 0) { sbResponse.Append(utfEncode.GetString(byteStream, 0, byteCount)); try { byteCount = response_stream.Read(byteStream, 0, 512); } catch { //Micros don't terminate their output stream correctly and just close the connection resulting in an exception at our end byteCount = 0; } } response_text = sbResponse.ToString(); if (response_text == string.Empty) response_text = response.StatusCode.ToString(); } stream.Close(); } catch (WebException webEx) { //throw webEx; } catch (Exception ex) { //throw ex; } }</thread></thread> |
0 comments:
Post a Comment