c#多執行緒開發-有解無憂

        //要執行的業務是從阿里云上下載將近40000條的音頻到本地，單條下載忒慢，就想采用多執行緒，分配了二十個執行緒同時下載，省了很大部分的時間

          class Program
  2     {
  3        
  4         static void Main(string[] args) {
  5             string sql = "select en_audio,us_audio from t_audio LIMIT 198 ";
  6             MySqlDataReader mySqlDataReader = DBHelper.ExecuteReader(sql);         
  7             List<String> sList = new List<String>();
  8             sList.Add("https://qutifen-qudao.oss-cn-beijing.aliyuncs.com/mfg/audio/v3/1abacus_en.ogg");
  9             sList.Add("https://qutifen-qudao.oss-cn-beijing.aliyuncs.com/mfg/audio/v3/2abacus_en.ogg");
 10             if (mySqlDataReader.HasRows)
 11             {
 12                 while (mySqlDataReader.Read())
 13                 {                 
 14                     sList.Add(mySqlDataReader.GetString(0));
 15                     sList.Add(mySqlDataReader.GetString(1));
 16                 }
 17             }              
 18             Console.WriteLine(sList.Count);
 19             Stopwatch stopwatch = new Stopwatch();
 20             stopwatch.Start();
 21             ThreadStart(sList);
 22             WaitHandle.WaitAll(waits);  //監聽wait里面的所有的執行緒都已經set了 才執行下面的代碼，否則一直在這里等待
 23             stopwatch.Stop();
 24             Console.WriteLine($"耗時{stopwatch.ElapsedMilliseconds}毫秒");
 25             Console.ReadKey();
 26 
 27 
 28         }
 29        static  Thread[] threads = new Thread[20];
 30         static WaitHandle[] waits = new WaitHandle[20];
 31         public  static void ThreadStart(List<String> nums) {
                  //分配執行緒
 32             for (int i=0;i<20;i++) {
 33                 threads[i] = new Thread(DownLoadFile);
 34                 waits[i] = new AutoResetEvent(false);
 35 
 36             }
                 //為每個執行緒分配要執行的資料并開始執行
 37             for (int i = 0; i < 20; i++)
 38             {
 39                 if (i== threads.Length-1) {
 40                     var retult = nums.Skip(nums.Count / 20 * i).Take(nums.Count- nums.Count / 20*i).ToList();
 41                     threads[i].Start(new Objpt()
 42                     {
 43                         sList = retult,
 44                         WaitHandle = waits[i],
 45                         ThreadIndex = i
 46                     });
 47                 }
 48                 else {
 49                   var retult= nums.Skip(nums.Count / 20 * i).Take(nums.Count / 20).ToList();
 50                     threads[i].Start(new Objpt() { 
 51                      sList= retult,
 52                      WaitHandle=waits[i],
 53                      ThreadIndex=i
 54                     });
 55                 }
 56                
 57             }
 58         }
 59 
 60         public static void DownLoadFile(Object obj)
 61         {
 62             int count = 0;
 63             Objpt optObj = (obj as Objpt);
 64             var sList = optObj.sList;
 65             Console.WriteLine($"執行緒{optObj.ThreadIndex}開始了");
 66             foreach (var url in sList)
 67             {
 68                 try
 69                 {
 70                     count++;
 71                     var arrs = url.Split('/');
 72                     WebRequest request = WebRequest.Create(url);
 73                     HttpWebResponse res = (HttpWebResponse)request.GetResponse();
 74                     WebResponse response = request.GetResponse();           
 75                     if (res.StatusCode.ToString() == "OK")
 76                     {
 77                         Stream responseStream = response.GetResponseStream();
 78                         using (FileStream fsWrite = new FileStream($"F:/Audio/v4/{arrs[arrs.Length - 2]}/{arrs[arrs.Length - 1]}", FileMode.OpenOrCreate, FileAccess.Write))
 79                         {
 80                             byte[] buffer = new byte[response.ContentLength];
 81                             while (true)
 82                             {
 83                                 ////回傳本次實際讀取到的位元組數
 84                                 int r = responseStream.Read(buffer, 0, buffer.Length);
 85                                 if (r == 0)
 86                                 {
 87                                     break;
 88                                 }
 89                                 fsWrite.Write(buffer, 0, r);///寫入
 90 
 91                             }
 92                         }
 93                     }
 94                     //if (count % 20 == 0 || count == sList.Count)
 95                     //{
 96                     //    Console.WriteLine($"執行緒{optObj.ThreadIndex}已處理個數：{count}");
 97                     //}
 98 
 99                 }
100                 catch (Exception ex)
101                 {
102                     string strErrorLogFile = System.AppDomain.CurrentDomain.BaseDirectory + $"\\{optObj.ThreadIndex}ErrorLog.log";
103                     if (!System.IO.File.Exists(strErrorLogFile))
104                         System.IO.File.WriteAllText(strErrorLogFile, "//系統錯誤日志記錄檔案\r\n");
105                     object objSql ="執行緒"+ optObj.ThreadIndex.ToString()+ ex.Message;
106                     System.IO.File.AppendAllText(strErrorLogFile, DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") + "\t" + objSql.ToString() + url + "\r\n");
107 
108                 }
109 
110             }
111             Console.WriteLine($"執行緒{optObj.ThreadIndex}結束");
112             (optObj.WaitHandle as AutoResetEvent).Set();  //set方法是當某個執行緒結束起做個標記的作用
113         }
114     }
115 
116      public class Objpt {
117         public List<String> sList { get; set; }
118         public WaitHandle WaitHandle { get; set; }
119         public int ThreadIndex { get; set; }
120 
121     }

private static AutoResetEvent myAutoRetEvent = new AutoResetEvent(false);
// true:設定終止狀態（不阻塞），相當于呼叫了Set(),即首次不會被WaitOne()阻塞，下次執行WaitOne()才會被阻塞
//false:設定非終止狀態（阻塞），遇到WaitOne()立即阻塞所在的一個或多個執行緒

//public bool Set(); //將事件狀態設定為終止狀態，從而允許繼續執行一個或多個等待執行緒，
//public bool Reset();//將事件狀態設定為非終止，從而導致執行緒受阻，

static void Main(string[] args)
{
//來了一個顧客1
Thread myThread1 = new Thread(new ThreadStart(Run_1));
myThread1.Start();
//來了一個顧客2
Thread myThread2 = new Thread(new ThreadStart(Run_2));
myThread2.Start();

//廚師做飯做3000ms
Thread.Sleep(3000);
//廚師做好飯了，通知看誰能吃上飯
myAutoRetEvent.Set(); //Run_2不會被執行，只有Run_1執行
Console.ReadKey();
}

private static void Run_1()
{
//顧客1過來了，要吃飯，等廚師做好飯
myAutoRetEvent.WaitOne();
Console.WriteLine("我是顧客1開始吃飯...");

}

private static void Run_2()
{
//顧客2過來了，要吃飯，等廚師做好飯
myAutoRetEvent.WaitOne();
Console.WriteLine("我是顧客2開始吃飯...");
}

等待3秒后，彈出“我是顧客1開始吃飯...”，如果把建構式中的false改為true，單擊按鈕后，立即彈出“我是顧客1開始吃飯...”，

.ManualResetEvent 呼叫一次Set()后將允許恢復所有被阻塞執行緒,即Run_1，Run_2都會被執行；
.AutoResetEvent,呼叫一次Set()只能繼續被阻塞的一個執行緒，即Run_2不會被執行，只有Run_1執行，多次呼叫Set()才行

AutoResetEvent和ManualResetEvent實體化，如果為 true，則將初始狀態設定為終止（不阻塞）；如果為 false，則將初始狀態設定為非終止（阻塞），

//將事件狀態設定為終止狀態，從而允許繼續執行一個或多個等待執行緒，
//public bool Set();
//將事件狀態設定為非終止，從而導致執行緒受阻，
//public bool Reset();

http://blog.sina.com.cn/s/blog_6f19490b0102x4c4.html

WaitOne：在一個執行緒MainThread中開啟一個新的執行緒NewThread，在完成初始化并啟動NewThread的操作后，呼叫WaitOne，則MainThread堵塞，直到在NewThread中呼叫Set，MainThread才繼續執行，

AutoResetEvent 允許執行緒通過發信號互相通信，通常，此通信涉及執行緒需要獨占訪問的資源，

執行緒通過呼叫 AutoResetEvent 上的 WaitOne 來等待信號，如果 AutoResetEvent 處于非終止狀態，則該執行緒阻塞，并等待當前控制資源的執行緒通過呼叫 Set 發出資源可用的信號，

呼叫 Set 向 AutoResetEvent 發信號以釋放等待執行緒，AutoResetEvent 將保持終止狀態，直到一個正在等待的執行緒被釋放，然后自動回傳非終止狀態，如果沒有任何執行緒在等待，則狀態將無限期地保持為終止狀態，

可以通過將一個布林值傳遞給建構式來控制 AutoResetEvent 的初始狀態，如果初始狀態為終止狀態，則為 true；否則為 false，

通俗的來講只有等myResetEven.Set()成功運行后,myResetEven.WaitOne()才能夠獲得運行機會;Set是發信號，WaitOne是等待信號，只有發了信號，等待的才會執行，如果不發的話，WaitOne后面的程式就永遠不會執行，

轉載請註明出處，本文鏈接：https://www.uj5u.com/net/93262.html

標籤：C#

上一篇：C#界面設計相關設定

下一篇：C# MySql Transaction Async