c#多線程開發

来源:https://www.cnblogs.com/DSC1991/archive/2019/12/10/12018316.html

1 //要執行的業務是從阿裡雲上下載將近40000條的音頻到本地,單條下載忒慢,就想採用多線程,分配了二十個線程同時下載,省了很大部分的時間 class Program 2 { 3 4 static void Main(string[] args) { 5 string sql = "select ... ...


  1
        //要執行的業務是從阿裡雲上下載將近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 }

 


您的分享是我們最大的動力!

更多相關文章
  • 前言 最近在實習,在公司看到前輩的一些代碼,發現有很多值得我學習的地方,其中有一部分就是對集合使用Stream流式操作,覺得很優美且方便。所以學習一些Stream流,在這裡記錄一下。 Stream是什麼 Stream 是Java 8中出現的新特性,極大增強了集合對象的功能,專註於對集合對象進行方便、 ...
  • 資料庫 tcp協程實現併發 回顧 一、回顧 進程池,線程池,回調函數 二、tcp服務端實現協程 演示 三、資料庫安裝以及修改配置等操作 理論知識加語法 ...
  • Scala中sortBy是以方法的形式存在的,並且是作用在Array或List集合排序上,並且這個sortBy預設只能升序,除非實現隱式轉換或調用reverse方法才能實現降序,Spark中sortBy是運算元,作用出發RDD中數據進行排序,預設是升序可以通過該運算元的第二參數來實現降序排序的方式 ...
  • 本筆記摘抄自:https://www.cnblogs.com/zhili/archive/2012/07/23/Mutex_And_Semaphore.html,記錄一下學習過程以備後續查用。 一、信號量(Semaphore) 信號量(Semaphore)是由內核對象維護的int變數。當信號量為0時 ...
  • 1.24小時時間格式制定 按照2019-12-10-13-00-00格式輸出:string dtnow = string.Format("{0:yyyy-MM-dd-HH-mm-ss}", DateTime.Now); //24小時制 按照2019-12-10-01-00-00格式輸出:string ...
  • 當新建一個core項目後,使用identity基架後,確認郵件出現了錯誤,並不能正常使用。 建立文檔在這裡 https://docs.microsoft.com/zh-cn/aspnet/core/security/authentication/scaffold-identity?view=aspn ...
  • From https://www.cnblogs.com/zjbky/p/9242140.html ...
  • using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.Threading.Tasks; using System.Data; using System.Co... ...
一周排行
  • 比如要拆分“呵呵呵90909086676喝喝999”,下麵當type=0返回的是中文字元串“呵呵呵,喝喝”,type=1返回的是數字字元串“90909086676,999”, private string GetStrings(string str,int type=0) { IList<strin ...
  • Swagger一個優秀的Api介面文檔生成工具。Swagger可以可以動態生成Api介面文檔,有效的降低前後端人員關於Api介面的溝通成本,促進項目高效開發。 1、使用NuGet安裝最新的包:Swashbuckle.AspNetCore。 2、編輯項目文件(NetCoreTemplate.Web.c ...
  • 2020 年 7 月 30 日, 由.NET基金會和微軟 將舉辦一個線上和為期一天的活動,包括 微軟 .NET 團隊的演講者以及社區的演講者。本次線上大會 專註.NET框架構建微服務,演講者分享構建和部署雲原生應用程式的最佳實踐、模式、提示和技巧。有關更多信息和隨時瞭解情況:https://focu... ...
  • #abp框架Excel導出——基於vue #1.技術棧 ##1.1 前端採用vue,官方提供 UI套件用的是iview ##1.2 後臺是abp——aspnetboilerplate 即abp v1,https://github.com/aspnetboilerplate/aspnetboilerp ...
  • 前言 本文的文字及圖片來源於網路,僅供學習、交流使用,不具有任何商業用途,版權歸原作者所有,如有問題請及時聯繫我們以作處理。 作者:碧茂大數據 PS:如有需要Python學習資料的小伙伴可以加下方的群去找免費管理員領取 input()輸入 Python提供了 input() 內置函數從標準輸入讀入一 ...
  • 從12年到20年,python以肉眼可見的趨勢超過了java,成為了當今It界人人皆知的編程語言。 python為什麼這麼火? 網路編程語言搜索指數 適合初學者 Python具有語法簡單、語句清晰的特點,這就讓初學者在學習階段可以把精力集中在編程對象和思維方法上。 大佬都在用 Google,YouT ...
  • 在社會上存在一種普遍的對培訓機構的學生一種歧視的現象,具體表現在,比如:當你去公司面試的時候,一旦你說了你是培訓機構出來的,那麼基本上你就涼了,那麼你瞞著不說,然後又通過了面試成功入職,但是以後一旦在公司被髮現有培訓經歷,可能會面臨被降薪,甚至被辭退,培訓機構出來的學生,在用人單位眼裡就是能力低下的 ...
  • from typing import List# 這道題看了大佬寫的代碼,經過自己的理解寫出來了。# 從最外圍的四周找有沒有為O的,如果有的話就進入深搜函數,然後深搜遍歷# 判斷上下左右的位置是否為Oclass Solution: def solve(self, board: List[List[s ...
  • import requests; import re; import os; # 1.請求網頁 header = { "user-agent":'Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_5) AppleWebKit/537.36 (KHTML, li ...
  • import requests; import re; import os; import parsel; 1.請求網頁 header = { "user-agent":'Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_5) AppleWebKit/537. ...