c#多線程開發

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

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 }

 


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

-Advertisement-
Play Games
更多相關文章
  • 前言 最近在實習,在公司看到前輩的一些代碼,發現有很多值得我學習的地方,其中有一部分就是對集合使用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... ...
一周排行
    -Advertisement-
    Play Games
  • Timer是什麼 Timer 是一種用於創建定期粒度行為的機制。 與標準的 .NET System.Threading.Timer 類相似,Orleans 的 Timer 允許在一段時間後執行特定的操作,或者在特定的時間間隔內重覆執行操作。 它在分散式系統中具有重要作用,特別是在處理需要周期性執行的 ...
  • 前言 相信很多做WPF開發的小伙伴都遇到過表格類的需求,雖然現有的Grid控制項也能實現,但是使用起來的體驗感並不好,比如要實現一個Excel中的表格效果,估計你能想到的第一個方法就是套Border控制項,用這種方法你需要控制每個Border的邊框,並且在一堆Bordr中找到Grid.Row,Grid. ...
  • .NET C#程式啟動閃退,目錄導致的問題 這是第2次踩這個坑了,很小的編程細節,容易忽略,所以寫個博客,分享給大家。 1.第一次坑:是windows 系統把程式運行成服務,找不到配置文件,原因是以服務運行它的工作目錄是在C:\Windows\System32 2.本次坑:WPF桌面程式通過註冊表設 ...
  • 在分散式系統中,數據的持久化是至關重要的一環。 Orleans 7 引入了強大的持久化功能,使得在分散式環境下管理數據變得更加輕鬆和可靠。 本文將介紹什麼是 Orleans 7 的持久化,如何設置它以及相應的代碼示例。 什麼是 Orleans 7 的持久化? Orleans 7 的持久化是指將 Or ...
  • 前言 .NET Feature Management 是一個用於管理應用程式功能的庫,它可以幫助開發人員在應用程式中輕鬆地添加、移除和管理功能。使用 Feature Management,開發人員可以根據不同用戶、環境或其他條件來動態地控制應用程式中的功能。這使得開發人員可以更靈活地管理應用程式的功 ...
  • 在 WPF 應用程式中,拖放操作是實現用戶交互的重要組成部分。通過拖放操作,用戶可以輕鬆地將數據從一個位置移動到另一個位置,或者將控制項從一個容器移動到另一個容器。然而,WPF 中預設的拖放操作可能並不是那麼好用。為瞭解決這個問題,我們可以自定義一個 Panel 來實現更簡單的拖拽操作。 自定義 Pa ...
  • 在實際使用中,由於涉及到不同編程語言之間互相調用,導致C++ 中的OpenCV與C#中的OpenCvSharp 圖像數據在不同編程語言之間難以有效傳遞。在本文中我們將結合OpenCvSharp源碼實現原理,探究兩種數據之間的通信方式。 ...
  • 一、前言 這是一篇搭建許可權管理系統的系列文章。 隨著網路的發展,信息安全對應任何企業來說都越發的重要,而本系列文章將和大家一起一步一步搭建一個全新的許可權管理系統。 說明:由於搭建一個全新的項目過於繁瑣,所有作者將挑選核心代碼和核心思路進行分享。 二、技術選擇 三、開始設計 1、自主搭建vue前端和. ...
  • Csharper中的表達式樹 這節課來瞭解一下表示式樹是什麼? 在C#中,表達式樹是一種數據結構,它可以表示一些代碼塊,如Lambda表達式或查詢表達式。表達式樹使你能夠查看和操作數據,就像你可以查看和操作代碼一樣。它們通常用於創建動態查詢和解析表達式。 一、認識表達式樹 為什麼要這樣說?它和委托有 ...
  • 在使用Django等框架來操作MySQL時,實際上底層還是通過Python來操作的,首先需要安裝一個驅動程式,在Python3中,驅動程式有多種選擇,比如有pymysql以及mysqlclient等。使用pip命令安裝mysqlclient失敗應如何解決? 安裝的python版本說明 機器同時安裝了 ...