亚洲香蕉成人av网站在线观看_欧美精品成人91久久久久久久_久久久久久久久久久亚洲_热久久视久久精品18亚洲精品_国产精自产拍久久久久久_亚洲色图国产精品_91精品国产网站_中文字幕欧美日韩精品_国产精品久久久久久亚洲调教_国产精品久久一区_性夜试看影院91社区_97在线观看视频国产_68精品久久久久久欧美_欧美精品在线观看_国产精品一区二区久久精品_欧美老女人bb

首頁 > 編程 > C# > 正文

C#使用讀寫鎖三行代碼簡單解決多線程并發的問題

2019-10-29 21:17:17
字體:
來源:轉載
供稿:網友

在開發程序的過程中,難免少不了寫入錯誤日志這個關鍵功能。實現這個功能,可以選擇使用第三方日志插件,也可以選擇使用數據庫,還可以自己寫個簡單的方法把錯誤信息記錄到日志文件。

選擇最后一種方法實現的時候,若對文件操作與線程同步不熟悉,問題就有可能出現了,因為同一個文件并不允許多個線程同時寫入,否則會提示“文件正在由另一進程使用,因此該進程無法訪問此文件”。

這是文件的并發寫入問題,就需要用到線程同步。而微軟也給線程同步提供了一些相關的類可以達到這樣的目的,本文使用到的 System.Threading.ReaderWriterLockSlim 便是其中之一。

該類用于管理資源訪問的鎖定狀態,可實現多線程讀取或進行獨占式寫入訪問。利用這個類,我們就可以避免在同一時間段內多線程同時寫入一個文件而導致的并發寫入問題。

讀寫鎖是以 ReaderWriterLockSlim 對象作為鎖管理資源的,不同的 ReaderWriterLockSlim 對象中鎖定同一個文件也會被視為不同的鎖進行管理,這種差異可能會再次導致文件的并發寫入問題,所以 ReaderWriterLockSlim 應盡量定義為只讀的靜態對象。

ReaderWriterLockSlim 有幾個關鍵的方法,本文僅討論寫入鎖:

調用 EnterWriteLock 方法 進入寫入狀態,在調用線程進入鎖定狀態之前一直處于阻塞狀態,因此可能永遠都不返回。

調用 TryEnterWriteLock 方法 進入寫入狀態,可指定阻塞的間隔時間,如果調用線程在此間隔期間并未進入寫入模式,將返回false。

調用 ExitWriteLock 方法 退出寫入狀態,應使用 finally 塊執行 ExitWriteLock 方法,從而確保調用方退出寫入模式。

Don't talk, show me the code.

1.多線程同時寫入文件

class Program { static int LogCount = 100; static int WritedCount = 0; static int FailedCount = 0; static void Main(string[] args) { //迭代運行寫入日志記錄,由于多個線程同時寫入同一個文件將會導致錯誤 Parallel.For(0, LogCount, e => { WriteLog(); }); Console.WriteLine(string.Format("/r/nLog Count:{0}./t/tWrited Count:{1}./tFailed Count:{2}.", LogCount.ToString(), WritedCount.ToString(), FailedCount.ToString())); Console.Read(); } static void WriteLog() { try { var logFilePath = "log.txt"; var now = DateTime.Now; var logContent = string.Format("Tid: {0}{1} {2}.{3}/r/n", Thread.CurrentThread.ManagedThreadId.ToString().PadRight(4), now.ToLongDateString(), now.ToLongTimeString(), now.Millisecond.ToString()); File.AppendAllText(logFilePath, logContent); WritedCount++; } catch (Exception ex) { FailedCount++; Console.WriteLine(ex.Message); } } }

運行結果:

C#,讀寫鎖,多線程

不使用讀寫鎖,只有部分日志成功寫入了日志文件。

2.多線程使用讀寫鎖同步寫入文件

class Program { static int LogCount = 100; static int WritedCount = 0; static int FailedCount = 0; static void Main(string[] args) { //迭代運行寫入日志記錄 Parallel.For(0, LogCount, e => { WriteLog(); }); Console.WriteLine(string.Format("/r/nLog Count:{0}./t/tWrited Count:{1}./tFailed Count:{2}.", LogCount.ToString(), WritedCount.ToString(), FailedCount.ToString())); Console.Read(); } //讀寫鎖,當資源處于寫入模式時,其他線程寫入需要等待本次寫入結束之后才能繼續寫入 static ReaderWriterLockSlim LogWriteLock = new ReaderWriterLockSlim(); static void WriteLog() { try { //設置讀寫鎖為寫入模式獨占資源,其他寫入請求需要等待本次寫入結束之后才能繼續寫入 //注意:長時間持有讀線程鎖或寫線程鎖會使其他線程發生饑餓 (starve)。 為了得到最好的性能,需要考慮重新構造應用程序以將寫訪問的持續時間減少到最小。 // 從性能方面考慮,請求進入寫入模式應該緊跟文件操作之前,在此處進入寫入模式僅是為了降低代碼復雜度 // 因進入與退出寫入模式應在同一個try finally語句塊內,所以在請求進入寫入模式之前不能觸發異常,否則釋放次數大于請求次數將會觸發異常 LogWriteLock.EnterWriteLock(); var logFilePath = "log.txt"; var now = DateTime.Now; var logContent = string.Format("Tid: {0}{1} {2}.{3}/r/n", Thread.CurrentThread.ManagedThreadId.ToString().PadRight(4), now.ToLongDateString(), now.ToLongTimeString(), now.Millisecond.ToString()); File.AppendAllText(logFilePath, logContent); WritedCount++; } catch (Exception) { FailedCount++; } finally { //退出寫入模式,釋放資源占用 //注意:一次請求對應一次釋放 // 若釋放次數大于請求次數將會觸發異常[寫入鎖定未經保持即被釋放] // 若請求處理完成后未釋放將會觸發異常[此模式不下允許以遞歸方式獲取寫入鎖定] LogWriteLock.ExitWriteLock(); } } }

運行結果:

C#,讀寫鎖,多線程

使用讀寫鎖,全部日志成功寫入了日志文件。

3.測試復雜多線程環境下使用讀寫鎖同步寫入文件

 class Program { static int LogCount = 1000; static int SumLogCount = 0; static int WritedCount = 0; static int FailedCount = 0; static void Main(string[] args) { //往線程池里添加一個任務,迭代寫入N個日志 SumLogCount += LogCount; ThreadPool.QueueUserWorkItem((obj) => { Parallel.For(0, LogCount, e => { WriteLog(); }); }); //在新的線程里,添加N個寫入日志的任務到線程池 SumLogCount += LogCount; var thread1 = new Thread(() => { Parallel.For(0, LogCount, e => { ThreadPool.QueueUserWorkItem((subObj) => { WriteLog(); }); }); }); thread1.IsBackground = false; thread1.Start(); //添加N個寫入日志的任務到線程池 SumLogCount += LogCount; Parallel.For(0, LogCount, e => { ThreadPool.QueueUserWorkItem((obj) => { WriteLog(); }); }); //在新的線程里,迭代寫入N個日志 SumLogCount += LogCount; var thread2 = new Thread(() => { Parallel.For(0, LogCount, e => { WriteLog(); }); }); thread2.IsBackground = false; thread2.Start(); //在當前線程里,迭代寫入N個日志 SumLogCount += LogCount; Parallel.For(0, LogCount, e => { WriteLog(); }); Console.WriteLine("Main Thread Processed./r/n"); while (true) { Console.WriteLine(string.Format("Sum Log Count:{0}./t/tWrited Count:{1}./tFailed Count:{2}.", SumLogCount.ToString(), WritedCount.ToString(), FailedCount.ToString())); Console.ReadLine(); } } //讀寫鎖,當資源處于寫入模式時,其他線程寫入需要等待本次寫入結束之后才能繼續寫入 static ReaderWriterLockSlim LogWriteLock = new ReaderWriterLockSlim(); static void WriteLog() { try { //設置讀寫鎖為寫入模式獨占資源,其他寫入請求需要等待本次寫入結束之后才能繼續寫入 //注意:長時間持有讀線程鎖或寫線程鎖會使其他線程發生饑餓 (starve)。 為了得到最好的性能,需要考慮重新構造應用程序以將寫訪問的持續時間減少到最小。 // 從性能方面考慮,請求進入寫入模式應該緊跟文件操作之前,在此處進入寫入模式僅是為了降低代碼復雜度 // 因進入與退出寫入模式應在同一個try finally語句塊內,所以在請求進入寫入模式之前不能觸發異常,否則釋放次數大于請求次數將會觸發異常 LogWriteLock.EnterWriteLock(); var logFilePath = "log.txt"; var now = DateTime.Now; var logContent = string.Format("Tid: {0}{1} {2}.{3}/r/n", Thread.CurrentThread.ManagedThreadId.ToString().PadRight(4), now.ToLongDateString(), now.ToLongTimeString(), now.Millisecond.ToString()); File.AppendAllText(logFilePath, logContent); WritedCount++; } catch (Exception) { FailedCount++; } finally { //退出寫入模式,釋放資源占用 //注意:一次請求對應一次釋放 // 若釋放次數大于請求次數將會觸發異常[寫入鎖定未經保持即被釋放] // 若請求處理完成后未釋放將會觸發異常[此模式不下允許以遞歸方式獲取寫入鎖定] LogWriteLock.ExitWriteLock(); } } }

運行結果:

C#,讀寫鎖,多線程

部分日志文件內容:

 ...Tid: 36 2016年12月11日 15:29:22.825Tid: 29 2016年12月11日 15:29:22.830Tid: 6 2016年12月11日 15:29:22.838Tid: 26 2016年12月11日 15:29:22.845Tid: 34 2016年12月11日 15:29:22.854Tid: 24 2016年12月11日 15:29:22.863Tid: 27 2016年12月11日 15:29:22.872Tid: 14 2016年12月11日 15:29:22.877Tid: 23 2016年12月11日 15:29:22.886Tid: 20 2016年12月11日 15:29:22.892Tid: 30 2016年12月11日 15:29:22.898Tid: 9 2016年12月11日 15:29:22.904Tid: 21 2016年12月11日 15:29:22.909Tid: 22 2016年12月11日 15:29:22.915Tid: 7 2016年12月11日 15:29:22.920Tid: 3 2016年12月11日 15:29:22.925Tid: 12 2016年12月11日 15:29:22.931Tid: 5 2016年12月11日 15:29:22.937Tid: 13 2016年12月11日 15:29:22.942Tid: 11 2016年12月11日 15:29:22.947Tid: 19 2016年12月11日 15:29:22.953Tid: 37 2016年12月11日 15:29:22.958Tid: 37 2016年12月11日 15:29:22.964Tid: 40 2016年12月11日 15:29:22.970Tid: 40 2016年12月11日 15:29:22.975Tid: 40 2016年12月11日 15:29:22.980Tid: 40 2016年12月11日 15:29:22.985Tid: 40 2016年12月11日 15:29:22.991Tid: 40 2016年12月11日 15:29:22.997Tid: 31 2016年12月11日 15:29:23.3Tid: 31 2016年12月11日 15:29:23.9Tid: 31 2016年12月11日 15:29:23.14Tid: 31 2016年12月11日 15:29:23.20Tid: 31 2016年12月11日 15:29:23.27Tid: 31 2016年12月11日 15:29:23.33Tid: 31 2016年12月11日 15:29:23.38Tid: 31 2016年12月11日 15:29:23.44Tid: 31 2016年12月11日 15:29:23.49Tid: 31 2016年12月11日 15:29:23.57Tid: 31 2016年12月11日 15:29:23.63Tid: 31 2016年12月11日 15:29:23.68Tid: 31 2016年12月11日 15:29:23.74Tid: 16 2016年12月11日 15:29:23.80Tid: 16 2016年12月11日 15:29:23.86Tid: 16 2016年12月11日 15:29:23.93Tid: 16 2016年12月11日 15:29:23.99Tid: 16 2016年12月11日 15:29:23.105Tid: 16 2016年12月11日 15:29:23.110Tid: 16 2016年12月11日 15:29:23.116Tid: 38 2016年12月11日 15:29:23.122Tid: 38 2016年12月11日 15:29:23.128Tid: 28 2016年12月11日 15:29:23.134Tid: 19 2016年12月11日 15:29:23.139Tid: 25 2016年12月11日 15:29:23.146Tid: 37 2016年12月11日 15:29:23.152Tid: 39 2016年12月11日 15:29:23.158Tid: 32 2016年12月11日 15:29:23.164Tid: 33 2016年12月11日 15:29:23.170Tid: 31 2016年12月11日 15:29:23.176Tid: 35 2016年12月11日 15:29:23.182Tid: 40 2016年12月11日 15:29:23.189Tid: 15 2016年12月11日 15:29:23.194Tid: 18 2016年12月11日 15:29:23.202Tid: 17 2016年12月11日 15:29:23.208Tid: 10 2016年12月11日 15:29:23.215Tid: 16 2016年12月11日 15:29:23.221

復雜多線程環境下使用讀寫鎖,全部日志成功寫入了日志文件,由ThreadId和DateTime可以看出是由不同的線程同步寫入。

以上就是本文的全部內容,希望本文的內容對大家的學習或者工作能帶來一定的幫助,同時也希望多多支持VEVB武林網!


注:相關教程知識閱讀請移步到c#教程頻道。
發表評論 共有條評論
用戶名: 密碼:
驗證碼: 匿名發表
亚洲香蕉成人av网站在线观看_欧美精品成人91久久久久久久_久久久久久久久久久亚洲_热久久视久久精品18亚洲精品_国产精自产拍久久久久久_亚洲色图国产精品_91精品国产网站_中文字幕欧美日韩精品_国产精品久久久久久亚洲调教_国产精品久久一区_性夜试看影院91社区_97在线观看视频国产_68精品久久久久久欧美_欧美精品在线观看_国产精品一区二区久久精品_欧美老女人bb
国产精品96久久久久久又黄又硬| 亚洲黄在线观看| 亚洲精品自拍视频| 国产精品高清免费在线观看| 欧美精品激情在线观看| 国产精品mp4| 伊人久久精品视频| 性色av香蕉一区二区| 91久久精品国产91性色| 一区二区三区无码高清视频| 日韩免费观看av| 国产精品白丝av嫩草影院| 国产成人拍精品视频午夜网站| 91沈先生作品| 欧美一区深夜视频| 欧美激情伊人电影| 成人免费网站在线观看| 爽爽爽爽爽爽爽成人免费观看| 久久人人爽亚洲精品天堂| 伊人久久大香线蕉av一区二区| 久久99久国产精品黄毛片入口| 欧美一级成年大片在线观看| 成人黄色中文字幕| 亚洲欧美日韩国产中文专区| 午夜精品久久久久久久久久久久久| 欧美野外猛男的大粗鳮| 欧美裸体男粗大视频在线观看| 国产精品专区第二| 色老头一区二区三区在线观看| 亚洲精品久久久久久久久久久| 亚洲国产精品久久| 亚洲国产精品va在线看黑人| 欧美一区二区视频97| 亚洲一区精品电影| 日韩欧美在线网址| 5566成人精品视频免费| 日本免费一区二区三区视频观看| 国产精品一区久久| 在线免费观看羞羞视频一区二区| 欧美激情videoshd| 国产一区二区三区在线观看网站| 亚洲黄色在线观看| 午夜精品视频网站| 精品久久久久久久久久| 亚洲一区二区三区乱码aⅴ| 亚洲第一精品自拍| 国产v综合v亚洲欧美久久| 在线成人激情黄色| 91爱视频在线| 日韩av大片免费看| 中文字幕国产精品久久| 国产精品无码专区在线观看| 欧美日韩精品在线视频| 日韩av在线影院| 亚洲香蕉av在线一区二区三区| 亚洲全黄一级网站| 亚洲肉体裸体xxxx137| 亚洲国产精品推荐| 成人免费视频xnxx.com| 91精品综合久久久久久五月天| 国产69精品久久久久久| 欧美精品久久久久a| 欧美成人手机在线| 日韩av在线一区二区| 亚洲视频国产视频| 91热福利电影| 日韩高清免费观看| 欧美午夜美女看片| 国产97人人超碰caoprom| 欧美日韩成人黄色| 亚洲深夜福利网站| 欧美精品videos另类日本| 欧美成人免费一级人片100| 国产成人精品视频| 91视频8mav| 日韩在线www| 亚洲аv电影天堂网| 91美女片黄在线观| 欧美午夜视频在线观看| 国产精品久久久久久久7电影| 欧美插天视频在线播放| 国产精品一区久久久| 尤物九九久久国产精品的特点| 国自产精品手机在线观看视频| 国产精品视频男人的天堂| 欧美xxxx做受欧美.88| 欧美视频免费在线观看| 国产精品久久久久久久久久99| 日本精品视频在线播放| 97视频色精品| 精品日本美女福利在线观看| 国产成人鲁鲁免费视频a| 97av视频在线| 欧美日韩国产第一页| 欧美网站在线观看| 国产精品xxx视频| 在线观看国产成人av片| 精品亚洲一区二区三区四区五区| 亚洲福利精品在线| 国产精品高潮呻吟视频| 国产欧美在线视频| 亚洲a一级视频| 国产精品揄拍一区二区| 亚洲开心激情网| 国产精品久久久久免费a∨| 狠狠躁夜夜躁久久躁别揉| 国产在线拍偷自揄拍精品| 性欧美激情精品| 国产精品久久婷婷六月丁香| 日韩风俗一区 二区| 亚洲一级黄色av| 久久亚洲精品成人| 欧美成年人视频网站欧美| 深夜福利日韩在线看| 福利视频导航一区| 日本a级片电影一区二区| 91精品啪aⅴ在线观看国产| 欧美亚洲第一页| 91在线视频免费| 国产精品男人爽免费视频1| 亚洲全黄一级网站| 精品福利一区二区| 欧美日韩在线观看视频| 亚洲无限av看| 成人免费视频在线观看超级碰| 欧美俄罗斯乱妇| 久久精品99久久香蕉国产色戒| 色婷婷**av毛片一区| 中文字幕九色91在线| 欧美乱大交xxxxx另类电影| 69av在线播放| 久久久久久久亚洲精品| 久久久久亚洲精品成人网小说| 国产免费一区二区三区在线能观看| 亚洲影视九九影院在线观看| 亚洲一区二区中文| 午夜精品国产精品大乳美女| 国产精品久在线观看| 91色中文字幕| 久久av中文字幕| 国产脚交av在线一区二区| 亚洲成人网av| 国产亚洲一级高清| 国产精品成人免费视频| 日韩在线观看网站| 亚洲午夜小视频| 亚洲图中文字幕| 粗暴蹂躏中文一区二区三区| 成人国产精品免费视频| 国产精品中文在线| 91av在线国产| 亚洲aⅴ日韩av电影在线观看| 中文字幕亚洲图片| 欧美激情国产日韩精品一区18| 精品视频久久久久久| 中文字幕在线看视频国产欧美| 日韩在线精品一区| 97在线看免费观看视频在线观看| 亚洲性日韩精品一区二区| 欧美日韩免费看| 一色桃子一区二区| 狠狠躁18三区二区一区| 国产极品精品在线观看| 久久91亚洲精品中文字幕奶水|