自拍偷在线精品自拍偷,亚洲欧美中文日韩v在线观看不卡

C# 多線程，論多核時代愛恨情仇

作者：請叫我頭頭哥
開發(fā) 后端
老板只有兩種，好的和壞的。好的老板只跟你談錢，壞的老板只跟你談理想。

博客前言

為什么要學習多線程？

  • 2010年1月21日是10年某市公務(wù)員考試的報名截止日。因從下午2點開始，用于報名的北京市人事考試網(wǎng)癱瘓，原定于昨天下午5點截止的報名時間延遲至今天上午11點。

  • 2011年3月11日下午5時（北京時間12日早9點）,蘋果發(fā)布新一代的平板電腦產(chǎn)品iPad 2，配備了A5.1Ghz雙核處理器，這寓意著平板電腦和筆記本一同進入"多核時代"。

  • 同年6月18日，國內(nèi)著名B2C---京東在周年慶典之際舉行了"隆重"的大規(guī)模的促銷活動，搶購隨之而來，訂單擠爆京東 限時達臨時取消。 昨天有消費者反映，由于點擊量過大，18日早上京東商城網(wǎng)站一度癱瘓。一位消費者說：“18日凌晨1點開始就登不上京東商城。”劉強東也表示：由于流量多 次超過4個G，服務(wù)器運行緩慢。 昨天，京東商城官網(wǎng)發(fā)布公告稱，“‘618’活動異?；鸨矣脩粝聠嗡俣瓤涨?，致使部分用戶已購訂單顯示出現(xiàn)延遲，用戶在一段時間內(nèi)無法在‘我的京東’中 查詢到自己的訂單。目前已購訂單顯示延遲的問題已得到有效解決，對此給您帶來的不便，我們深表歉意。”

  • 2015年05月05日登錄風信子網(wǎng)上商城發(fā)現(xiàn)，首頁除了廣告和相關(guān)消息外，只有“注冊賬號獲取更多優(yōu)惠”這唯一一個按鈕，沒有商品展示，沒有產(chǎn) 品搜索，不能網(wǎng)上下單，甚至連進入商城的按鈕也沒有。風信子南沙跨境商品直購體驗中心相關(guān)負責人表示，這主要是因為預約的人數(shù)太多，截至五一，預約人數(shù)已 超過十萬，太多人頻繁登陸，導致網(wǎng)店服務(wù)器癱瘓，目前技術(shù)人員還在努力維修中。該負責人介紹，體驗中心的網(wǎng)站目前正在調(diào)試，“網(wǎng)站目前的作用主要是給市民 預約和提前注冊，通過網(wǎng)絡(luò)注冊的市民不用在現(xiàn)場驗證身份證等信息，可以提高購買效率。”

下面通過一些實例來認識一下多線程和讓大家知道為什么要學習多線程。

[[157023]]

寫在前面

老板只有兩種，好的和壞的。好的老板只跟你談錢，壞的老板只跟你談理想。

v模擬場景

假設(shè)后臺有個monitor時事的在監(jiān)測訂單，且可以發(fā)現(xiàn)訂單然后處理訂單，每次(1次/S)可以處理1千個訂單，需要向倉庫系統(tǒng)發(fā)出指令，讓他們負責配送發(fā)貨。那么我們來寫一個EmulationSystem（模擬系統(tǒng)）

C# 多線程

JobHelper因為我們只是為了模擬一個環(huán)境，所以它是這樣的。

 

  1. //------------------------------------------------------------------------------ 
  2. // <copyright file="JobHelper.cs" company="CNBlogs Corporation" owner="請叫我頭頭哥"> 
  3. //     Copyright (C) 2015-2016 All Rights Reserved 
  4. //     原博文地址： http://www.cnblogs.com/toutou/ 
  5. // </copyright>  
  6. //------------------------------------------------------------------------------ 
  7. namespace CNBlogs.Common.Shared 
  8. { 
  9.     using System.Threading; 
  10.     /// <summary> 
  11.     /// Job helper 
  12.     /// </summary> 
  13.     public class JobHelper 
  14.     { 
  15.         /// <summary> 
  16.     /// Get job total count 
  17.         /// </summary> 
  18.     /// <returns></returns> 
  19.     public int GetJobCount() 
  20.         { 
  21.             // 我們的側(cè)重點是多線程，所以我們就模擬每次有1千個訂單，而模擬，所以我們不關(guān)心其他的。只要訂單數(shù)量。 
  22.     return 1000; 
  23.         } 
  24.         /// <summary> 
  25.     /// Submit job 
  26.         /// </summary> 
  27.     /// <param name="jobId">For job id</param> 
  28.     /// <returns>Submit job status</returns> 
  29.     public bool SubmitJob(int jobId) 
  30.         { 
  31.             // 假設(shè)針對每個訂單向后臺發(fā)送任務(wù)需要1秒，而且每個訂單都能成功發(fā)送 
  32.             Thread.Sleep(1000); 
  33.             return true; 
  34.         } 
  35.     } 
  36. } 

 

背景我們也交待完了，現(xiàn)在需要來得到這些訂單信息以后，向倉庫submit這些訂單。

v實戰(zhàn)演習

根據(jù)這種背景，我們可以有很多處理的辦法。

  • 傳統(tǒng)辦法:

    (開啟無腦模式：未使用多線程)

    代碼正文：

     

    1. //------------------------------------------------------------------------------ 
    2. // <copyright file="Runner.cs" company="CNBlogs Corporation" owner="請叫我頭頭哥"> 
    3. //     Copyright (C) 2015-2016 All Rights Reserved 
    4. //     原博文地址： http://www.cnblogs.com/toutou/ 
    5. // </copyright>  
    6. //------------------------------------------------------------------------------ 
    7. namespace CNBlogs.EmulationSystem 
    8. { 
    9.     using System; 
    10.     using System.Threading; 
    11.     using CNBlogs.Common.Shared; 
    12.     class Runner 
    13.     { 
    14.         /// <summary> 
    15.                 /// Job helper 
    16.         /// </summary> 
    17.                 private static JobHelper jobHelper = new JobHelper(); 
    18.         /// <summary> 
    19.                 /// Runner lock 
    20.         /// </summary> 
    21.                 private static Mutex mutex; 
    22.         static void Main(string[] args) 
    23.         { 
    24.             // 記錄開始處理的時間 
    25.             DateTime paddingTime = DateTime.Now.ToLocalTime(); 
    26.             int orderCount = jobHelper.GetJobCount(); 
    27.             // 用一個指示調(diào)用線程是否應(yīng)擁有互斥體的初始所屬權(quán)的布爾值來初始化 Mutex 類的新實例。 
    28.             // 當前進程只能啟動一次 
    29.             mutex = new Mutex(false, "CNBlogs.EmulationSystem"); 
    30.             if (!mutex.WaitOne(0, false)) 
    31.             { 
    32.                 Console.Out.WriteLine("Monitor already running..."); 
    33.                 return; 
    34.             } 
    35.             for (int i = 0; i < orderCount; i++) 
    36.             { 
    37.                 // 假設(shè)i就是job id 
    38.                 jobHelper.SubmitJob(i); 
    39.             } 
    40.             // 記錄處理完成的時間 
    41.             DateTime completeTime = DateTime.Now.ToLocalTime(); 
    42.             var minutes = (completeTime - paddingTime).TotalSeconds; 
    43.             Console.WriteLine(string.Format("處理{0}個訂單，花費時間{1}秒", orderCount, minutes)); 
    44.         } 
    45.     } 
    46. } 

    PS:現(xiàn)在的這些個電商，動不動來個什么周年慶店慶什么雙11雙12的一頓突突，搞得咱這些老百姓就全部蜂擁而上，顯然如果用傳統(tǒng)的方法雖然不會出錯，但是老板肯定會找你喝茶。在多核時代用這種方法也只能恨鐵不成鋼了。所以這個方法是絕對不可取的。

  • Task方法：

    如果有對Task不是很熟悉的園友可以在這里解開心謎。

    代碼正文：

     

    1. //------------------------------------------------------------------------------ 
    2. // <copyright file="Runner.cs" company="CNBlogs Corporation" owner="請叫我頭頭哥"> 
    3. //     Copyright (C) 2015-2016 All Rights Reserved 
    4. //     原博文地址： http://www.cnblogs.com/toutou/ 
    5. // </copyright>  
    6. //------------------------------------------------------------------------------ 
    7. namespace CNBlogs.EmulationSystem 
    8. { 
    9.     using System; 
    10.     using System.Collections.Generic; 
    11.     using System.Threading; 
    12.     using System.Threading.Tasks; 
    13.     using CNBlogs.Common.Shared; 
    14.     class Runner 
    15.     { 
    16.         /// <summary> 
    17.                 /// Job helper 
    18.         /// </summary> 
    19.                 private static JobHelper jobHelper = new JobHelper(); 
    20.         /// <summary> 
    21.                 /// Runner lock 
    22.         /// </summary> 
    23.                 private static Mutex mutex; 
    24.         static void Main(string[] args) 
    25.         { 
    26.             // 記錄開始處理的時間 
    27.             DateTime paddingTime = DateTime.Now.ToLocalTime(); 
    28.             int orderCount = jobHelper.GetJobCount(); 
    29.             // 用一個指示調(diào)用線程是否應(yīng)擁有互斥體的初始所屬權(quán)的布爾值來初始化 Mutex 類的新實例。 
    30.             // 當前進程只能啟動一次 
    31.             mutex = new Mutex(false, "CNBlogs.EmulationSystem"); 
    32.             if (!mutex.WaitOne(0, false)) 
    33.             { 
    34.                 Console.Out.WriteLine("Monitor already running..."); 
    35.                 return; 
    36.             } 
    37.             var taskList = new List<Task>(); 
    38.             for (int i = 0; i < orderCount; i++) 
    39.             { 
    40.                 int temp=i; 
    41.                 taskList.Add(Task.Factory.StartNew(() => 
    42.                 { 
    43.                     // 假設(shè)i就是job id 
    44.                     jobHelper.SubmitJob(temp); 
    45.                 })); 
    46.             } 
    47.             // 等待所有task執(zhí)行完畢 
    48.             Task.WaitAll(taskList.ToArray()); 
    49.             // 記錄處理完成的時間 
    50.             DateTime completeTime = DateTime.Now.ToLocalTime(); 
    51.             var minutes = (completeTime - paddingTime).TotalSeconds; 
    52.             Console.WriteLine(string.Format("Complete: {0}，cost {1} s", orderCount, minutes)); 
    53.         } 
    54.     } 
    55. } 

     

    代碼效果：

    C# 多線程

    相信分別從有TASK和沒有TASK的這兩次demo中，可以清楚的發(fā)現(xiàn)多線程處理這些頻繁交互能力的魅力。你會愛上這個方法。確實提高的效率。但是問題也隨之而來，一個進程多線程的總數(shù)和大小是有要求的(這個取決于服務(wù)器的配置)，不是任由我們肆意的開采的。如果訂單太多，我們不控制task那是會拉仇恨的。task需要控制。

    C# 多線程

  • Semaphore：

    如果有對Semaphore不是很熟悉的園友可以在這里解開心謎。

    代碼正文： 

    1. //------------------------------------------------------------------------------ 
    2. // <copyright file="Runner.cs" company="CNBlogs Corporation" owner="請叫我頭頭哥"> 
    3. //     Copyright (C) 2015-2016 All Rights Reserved 
    4. //     原博文地址： http://www.cnblogs.com/toutou/ 
    5. // </copyright>  
    6. //------------------------------------------------------------------------------ 
    7. namespace CNBlogs.EmulationSystem 
    8. { 
    9.     using System; 
    10.     using System.Collections.Generic; 
    11.     using System.Threading; 
    12.     using System.Threading.Tasks; 
    13.     using CNBlogs.Common.Shared; 
    14.     class Runner 
    15.     { 
    16.         /// <summary> 
    17.                 /// Job helper 
    18.         /// </summary> 
    19.                 private static JobHelper jobHelper = new JobHelper(); 
    20.         /// <summary> 
    21.                 /// The locker used to lock the semaphore and thread. 
    22.         /// </summary> 
    23.                 private static object lockerObj = new object(); 
    24.         /// <summary> 
    25.                 /// The semaphore limit the thread number of get latest test info 
    26.         /// </summary> 
    27.                 private static Semaphore semaphoreLimit; 
    28.         /// <summary> 
    29.                 /// Runner lock 
    30.         /// </summary> 
    31.                 private static Mutex mutex; 
    32.         static void Main(string[] args) 
    33.         { 
    34.             // 記錄開始處理的時間 
    35.             DateTime paddingTime = DateTime.Now.ToLocalTime(); 
    36.             int orderCount = jobHelper.GetJobCount(); 
    37.             // 用一個指示調(diào)用線程是否應(yīng)擁有互斥體的初始所屬權(quán)的布爾值來初始化 Mutex 類的新實例。 
    38.             // 當前進程只能啟動一次 
    39.             mutex = new Mutex(false, "CNBlogs.EmulationSystem"); 
    40.             if (!mutex.WaitOne(0, false)) 
    41.             { 
    42.                 Console.Out.WriteLine("Monitor already running..."); 
    43.                 return; 
    44.             } 
    45.             // 假設(shè)我們的服務(wù)器一個進程只能接受的大小=當前線程大小*500 ps:500是設(shè)置信號量的最大值 
    46.                 int maxProcNumber = 500; 
    47.             using (semaphoreLimit = new Semaphore(0, maxProcNumber)) 
    48.             { 
    49.                 // 以指定的次數(shù)退出信號量并返回前一個計數(shù)。 
    50.                 semaphoreLimit.Release(maxProcNumber); 
    51.                 var taskList = new List<Task>(); 
    52.                 for (int i = 0; i < orderCount; i++) 
    53.                 { 
    54.                     int temp=i; 
    55.                     // 如果SubmitJob有IO或者其他容易因為沖突而引起異常的話，這里需要加上lock 
    56.                     //lock (lockerObj) 
    57.                     //{ 
    58.                         semaphoreLimit.WaitOne(); 
    59.                         taskList.Add(Task.Factory.StartNew(() => 
    60.                         { 
    61.                             // 假設(shè)i就是job id 
    62.                             jobHelper.SubmitJob(temp); 
    63.                             // 退出信號量并返回前一個計數(shù)。 
    64.                             semaphoreLimit.Release(); 
    65.                         })); 
    66.                     //} 
    67.                 } 
    68.                 // 等待所有task執(zhí)行完畢 
    69.                 Task.WaitAll(taskList.ToArray()); 
    70.             } 
    71.             // 記錄處理完成的時間 
    72.             DateTime completeTime = DateTime.Now.ToLocalTime(); 
    73.             var minutes = (completeTime - paddingTime).TotalSeconds; 
    74.             Console.WriteLine(string.Format("Complete: {0}，cost {1} s", orderCount, minutes)); 
    75.         } 
    76.     } 
    77. } 

    代碼效果：

v博客總結(jié)

多線程路還很長...

 

責任編輯：王雪燕 來源： 博客園
C#多線程
相關(guān)推薦

2024-06-07 00:09:50

2022-05-13 09:47:28

Docker容器

2022-09-02 12:13:22

TCPUDP場景

2020-11-24 10:13:20

測試開發(fā)管理

2025-01-03 09:39:04

2009-08-12 18:04:44

編寫C#多線程

2021-04-12 06:08:16

HiveSpark大數(shù)據(jù)

2009-09-04 15:09:48

C#多線程啟動Squa

2009-08-28 16:43:57

C#多線程學習

2020-10-07 22:21:13

程序員技術(shù)線程

2021-05-10 23:28:29

vRANC-RANO-RAN

2024-08-07 08:22:27

2019-05-15 15:10:12

Tomcat Session Cookie

2009-07-17 10:37:05

C#多線程

2024-10-21 16:59:37

C#編程多線程

2020-04-09 15:26:55

間諜軟件NSOFacebook

2013-02-20 10:00:16

微軟CodePlexGitHub

2022-05-07 07:43:07

Redis存儲系統(tǒng)數(shù)據(jù)庫

2021-06-16 06:48:06

接口微信

2009-08-26 18:13:55

C#多線程lock
點贊
收藏

51CTO技術(shù)棧公眾號