架構師_程序員

 找回密碼
 注冊[Register]

QQ登錄

只需一步,快速開始

查看: 464|回復: 0
打印 上一主題 下一主題

[WinForm] c#多線程開發

[復制鏈接]
跳轉到指定樓層
樓主
發表于 2019-12-11 12:08:45 | 只看該作者
//要執行的業務是從阿里云上下載將近40000條的音頻到本地,單條下載忒慢,就想采用多線程,分配了二十個線程同時下載,省了很大部分的時間
          class Program
    {

        static void Main(string[] args) {
            string sql = "select en_audio,us_audio from t_audio LIMIT 198 ";
            MySqlDataReader mySqlDataReader = DBHelper.ExecuteReader(sql);         
            List<String> sList = new List<String>();
            sList.Add("https://qutifen-qudao.oss-cn-beijing.aliyuncs.com/mfg/audio/v3/1abacus_en.ogg");
            sList.Add("https://qutifen-qudao.oss-cn-beijing.aliyuncs.com/mfg/audio/v3/2abacus_en.ogg");
            if (mySqlDataReader.HasRows)
            {
                while (mySqlDataReader.Read())
                {                 
                    sList.Add(mySqlDataReader.GetString(0));
                    sList.Add(mySqlDataReader.GetString(1));
                }
            }              
            Console.WriteLine(sList.Count);
            Stopwatch stopwatch = new Stopwatch();
            stopwatch.Start();
            ThreadStart(sList);
            WaitHandle.WaitAll(waits);  //監聽wait里面的所有的線程都已經set了 才執行下面的代碼,否則一直在這里等待
            stopwatch.Stop();
            Console.WriteLine($"耗時{stopwatch.ElapsedMilliseconds}毫秒");
            Console.ReadKey();


        }
       static  Thread[] threads = new Thread[20];
        static WaitHandle[] waits = new WaitHandle[20];
        public  static void ThreadStart(List<String> nums) {
                  //分配線程
            for (int i=0;i<20;i++) {
                threads[i] = new Thread(DownLoadFile);
                waits[i] = new AutoResetEvent(false);

            }
                 //為每個線程分配要執行的數據并開始執行
            for (int i = 0; i < 20; i++)
            {
                if (i== threads.Length-1) {
                    var retult = nums.Skip(nums.Count / 20 * i).Take(nums.Count- nums.Count / 20*i).ToList();
                    threads[i].Start(new Objpt()
                    {
                        sList = retult,
                        WaitHandle = waits[i],
                        ThreadIndex = i
                    });
                }
                else {
                  var retult= nums.Skip(nums.Count / 20 * i).Take(nums.Count / 20).ToList();
                    threads[i].Start(new Objpt() {
                     sList= retult,
                     WaitHandle=waits[i],
                     ThreadIndex=i
                    });
                }

            }
        }

        public static void DownLoadFile(Object obj)
        {
            int count = 0;
            Objpt optObj = (obj as Objpt);
            var sList = optObj.sList;
            Console.WriteLine($"線程{optObj.ThreadIndex}開始了");
            foreach (var url in sList)
            {
                try
                {
                    count++;
                    var arrs = url.Split('/');
                    WebRequest request = WebRequest.Create(url);
                    HttpWebResponse res = (HttpWebResponse)request.GetResponse();
                    WebResponse response = request.GetResponse();           
                    if (res.StatusCode.ToString() == "OK")
                    {
                        Stream responseStream = response.GetResponseStream();
                        using (FileStream fsWrite = new FileStream($"F:/Audio/v4/{arrs[arrs.Length - 2]}/{arrs[arrs.Length - 1]}", FileMode.OpenOrCreate, FileAccess.Write))
                        {
                            byte[] buffer = new byte[response.ContentLength];
                            while (true)
                            {
                                ////返回本次實際讀取到的字節數
                                int r = responseStream.Read(buffer, 0, buffer.Length);
                                if (r == 0)
                                {
                                    break;
                                }
                                fsWrite.Write(buffer, 0, r);///寫入

                            }
                        }
                    }
                    //if (count % 20 == 0 || count == sList.Count)
                    //{
                    //    Console.WriteLine($"線程{optObj.ThreadIndex}已處理個數:{count}");
                    //}

                }
                catch (Exception ex)
                {
                    string strErrorLogFile = System.AppDomain.CurrentDomain.BaseDirectory + $"\\{optObj.ThreadIndex}ErrorLog.log";
                    if (!System.IO.File.Exists(strErrorLogFile))
                        System.IO.File.WriteAllText(strErrorLogFile, "//系統錯誤日志記錄文件\r\n");
                    object objSql ="線程"+ optObj.ThreadIndex.ToString()+ ex.Message;
                    System.IO.File.AppendAllText(strErrorLogFile, DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") + "\t" + objSql.ToString() + url + "\r\n");

                }

            }
            Console.WriteLine($"線程{optObj.ThreadIndex}結束");
            (optObj.WaitHandle as AutoResetEvent).Set();  //set方法是當某個線程結束起做個標記的作用
        }
    }

     public class Objpt {
        public List<String> sList { get; set; }
        public WaitHandle WaitHandle { get; set; }
        public int ThreadIndex { get; set; }

    }





上一篇:net/c# 如何實現dns劫持
下一篇:DateTime的使用
帖子永久地址: 

架構師_程序員 - 論壇版權1、本主題所有言論和圖片純屬會員個人意見,與本論壇立場無關
2、本站所有主題由該帖子作者發表,該帖子作者與架構師_程序員享有帖子相關版權
3、其他單位或個人使用、轉載或引用本文時必須同時征得該帖子作者和架構師_程序員的同意
4、帖子作者須承擔一切因本文發表而直接或間接導致的民事或刑事法律責任
5、本帖部分內容轉載自其它媒體,但并不代表本站贊同其觀點和對其真實性負責
6、如本帖侵犯到任何版權問題,請立即告知本站,本站將及時予與刪除并致以最深的歉意
7、架構師_程序員管理員和版主有權不事先通知發貼者而刪除本文

碼農網,只發表在實踐過程中,遇到的技術難題,不誤導他人。
您需要登錄后才可以回帖 登錄 | 注冊[Register]

本版積分規則

免責聲明:
碼農網所發布的一切軟件、編程資料或者文章僅限用于學習和研究目的;不得將上述內容用于商業或者非法用途,否則,一切后果請用戶自負。本站信息來自網絡,版權爭議與本站無關。您必須在下載后的24個小時之內,從您的電腦中徹底刪除上述內容。如果您喜歡該程序,請支持正版軟件,購買注冊,得到更好的正版服務。如有侵權請郵件與我們聯系處理。

Mail To:help@itsvse.com

QQ|Archiver|手機版|小黑屋|架構師 ( 魯ICP備14021824號-2 )|網站地圖

GMT+8, 2020-7-11 06:37

Powered by Discuz! X3.4

Copyright © 2001-2020, Tencent Cloud.

快速回復 返回頂部 返回列表
捕鸟达人老版