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

首頁 > 編程 > C# > 正文

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

2020-01-24 00:53:24
字體:
來源:轉載
供稿:網友

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

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

這是文件的并發寫入問題,就需要用到線程同步。而微軟也給線程同步提供了一些相關的類可以達到這樣的目的,本文使用到的 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); } } }

運行結果:

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

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(); } } }

運行結果:

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

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(); } } }

運行結果:

部分日志文件內容:

 ...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可以看出是由不同的線程同步寫入。

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

發表評論 共有條評論
用戶名: 密碼:
驗證碼: 匿名發表
亚洲香蕉成人av网站在线观看_欧美精品成人91久久久久久久_久久久久久久久久久亚洲_热久久视久久精品18亚洲精品_国产精自产拍久久久久久_亚洲色图国产精品_91精品国产网站_中文字幕欧美日韩精品_国产精品久久久久久亚洲调教_国产精品久久一区_性夜试看影院91社区_97在线观看视频国产_68精品久久久久久欧美_欧美精品在线观看_国产精品一区二区久久精品_欧美老女人bb
亚洲精品国产精品久久清纯直播| 伊人久久免费视频| 国产一区二区三区免费视频| 国产伦精品免费视频| 国产在线精品自拍| 亚洲淫片在线视频| 亚洲已满18点击进入在线看片| 欧美激情精品久久久久久黑人| 久久久国产精品亚洲一区| 国产精品视频一区二区三区四| 国产精品成人一区二区三区吃奶| 日韩欧亚中文在线| 日韩一区二区三区xxxx| 懂色av中文一区二区三区天美| 欧美在线一级va免费观看| 国产精品久久精品| 欧美日韩亚洲视频一区| 国产精品久久国产精品99gif| 国产精品自拍网| 亚洲第一色中文字幕| 欧美自拍视频在线| 亚洲成人网久久久| 欧美日韩国产二区| 久久久极品av| 色综合伊人色综合网| 国产精品综合网站| 77777少妇光屁股久久一区| 亚洲最大福利网站| 亚洲国产一区二区三区四区| 热99在线视频| 亚洲xxxx18| 欧美国产精品va在线观看| 久久国产精品电影| 国产视频一区在线| 亚洲福利视频免费观看| 疯狂蹂躏欧美一区二区精品| 九九热视频这里只有精品| 亚洲欧美日韩国产精品| 亚洲国产精品美女| 国产精品欧美久久久| 热久久美女精品天天吊色| 日韩av大片在线| 91免费在线视频| 精品久久久久久久久中文字幕| 久久999免费视频| 在线视频国产日韩| 亚洲精品国产综合区久久久久久久| 欧美成人午夜视频| 亚洲香蕉成人av网站在线观看| 成人亚洲激情网| 欧美激情一区二区三区高清视频| 欧美日韩在线免费观看| 88国产精品欧美一区二区三区| 欧美激情精品久久久久久黑人| 国产91色在线|| 91精品国产91久久久| 精品电影在线观看| 国产精品自拍网| 欧美理论在线观看| 日韩精品久久久久| 丁香五六月婷婷久久激情| 国产日韩欧美电影在线观看| 国产盗摄xxxx视频xxx69| 欧美壮男野外gaytube| 精品香蕉在线观看视频一| 日韩av电影在线播放| 欧美日韩免费一区| 久久免费在线观看| 欧美性黄网官网| 国产精品一二三视频| 精品国产一区二区三区在线观看| 国产亚洲欧美aaaa| 国产精选久久久久久| 国产成人高清激情视频在线观看| 米奇精品一区二区三区在线观看| 亚洲欧美日韩在线一区| 国产亚洲欧美日韩一区二区| 欧美大片在线免费观看| 亚洲男人的天堂网站| 国产精品久久久91| 亚洲男人天堂手机在线| 国内精品免费午夜毛片| 51色欧美片视频在线观看| 久久99久久亚洲国产| 热re91久久精品国99热蜜臀| 亚洲人成啪啪网站| 日韩欧美在线国产| 欧美日本中文字幕| 日韩成人中文字幕在线观看| 亚洲精品国产精品久久清纯直播| 欧美电影免费观看大全| 欧美视频在线免费看| 欧美精品videosex性欧美| 欧美性猛交xxxx黑人猛交| 欧美性猛交丰臀xxxxx网站| 久久久综合免费视频| 国产精品一久久香蕉国产线看观看| 久久久久久久久久久人体| 欧美午夜久久久| 91在线精品播放| 日韩在线免费视频| 亚洲欧美日韩中文在线制服| 一区二区三欧美| 69久久夜色精品国产69| 精品国产区一区二区三区在线观看| 91精品国产自产在线老师啪| 亚洲精品视频在线播放| 2019中文字幕全在线观看| 国产精品欧美一区二区三区奶水| 国产一级揄自揄精品视频| 久久国产精品视频| 亚洲欧美自拍一区| 北条麻妃一区二区在线观看| 国产精品久久综合av爱欲tv| 2019中文字幕全在线观看| 国产精品女主播视频| 亚洲а∨天堂久久精品喷水| 国自在线精品视频| 国产精品美乳在线观看| 亚洲精品久久久久久久久久久久| 欧美裸体xxxx极品少妇软件| 久久国产精品免费视频| 亚洲一级黄色av| 欧美精品免费在线观看| 欧美成人精品影院| 欧美电影《睫毛膏》| 国产69精品久久久久9999| 亚洲第一黄色网| 精品国产乱码久久久久酒店| 欧洲亚洲免费在线| 久久久精品久久| 亚洲天堂av综合网| 韩国视频理论视频久久| 久久久久久久91| 欧美刺激性大交免费视频| 久久婷婷国产麻豆91天堂| 欧美亚洲在线观看| 国产日韩欧美在线播放| 亚洲国产精品大全| 欧美日韩成人在线观看| 国产在线观看不卡| 亚洲美女性视频| 久久影院资源网| 亚洲香蕉伊综合在人在线视看| 亚洲**2019国产| 久久精品国产2020观看福利| 亚洲永久免费观看| 久青草国产97香蕉在线视频| 中文字幕av日韩| 日韩高清欧美高清| 国产精品99久久久久久久久| 国产精品亚洲网站| 国产成人精品久久二区二区91| 欧美高清视频免费观看| 亚洲免费精彩视频| 91在线精品播放| 国产精品国模在线| 久久久久久18| 亚洲国产高潮在线观看| 日韩av最新在线观看| 久久综合伊人77777蜜臀| 91免费在线视频网站| 日韩成人性视频| 欧美极品第一页|