C#使用讀寫鎖三行代碼簡單解決多線程并發(fā)的問題
更新時間：2016年12月12日 09:43:51 作者：弎吩鍾熱℃
本文主要介紹了C#使用讀寫鎖三行代碼簡單解決多線程并發(fā)寫入文件時提示“文件正在由另一進程使用，因此該進程無法訪問此文件”的問題。需要的朋友可以參考借鑒
在開發(fā)程序的過程中，難免少不了寫入錯誤日志這個關鍵功能。實現這個功能，可以選擇使用第三方日志插件，也可以選擇使用數據庫，還可以自己寫個簡單的方法把錯誤信息記錄到日志文件。
選擇最后一種方法實現的時候，若對文件操作與線程同步不熟悉，問題就有可能出現了，因為同一個文件并不允許多個線程同時寫入，否則會提示“文件正在由另一進程使用，因此該進程無法訪問此文件”。
這是文件的并發(fā)寫入問題，就需要用到線程同步。而微軟也給線程同步提供了一些相關的類可以達到這樣的目的，本文使用到的 System.Threading.ReaderWriterLockSlim 便是其中之一。
該類用于管理資源訪問的鎖定狀態(tài)，可實現多線程讀取或進行獨占式寫入訪問。利用這個類，我們就可以避免在同一時間段內多線程同時寫入一個文件而導致的并發(fā)寫入問題。
讀寫鎖是以 ReaderWriterLockSlim 對象作為鎖管理資源的，不同的 ReaderWriterLockSlim 對象中鎖定同一個文件也會被視為不同的鎖進行管理，這種差異可能會再次導致文件的并發(fā)寫入問題，所以 ReaderWriterLockSlim 應盡量定義為只讀的靜態(tài)對象。
ReaderWriterLockSlim 有幾個關鍵的方法，本文僅討論寫入鎖：
調用 EnterWriteLock 方法 進入寫入狀態(tài)，在調用線程進入鎖定狀態(tài)之前一直處于阻塞狀態(tài)，因此可能永遠都不返回。
調用 TryEnterWriteLock 方法 進入寫入狀態(tài)，可指定阻塞的間隔時間，如果調用線程在此間隔期間并未進入寫入模式，將返回false。
調用 ExitWriteLock 方法 退出寫入狀態(tài)，應使用 finally 塊執(zhí)行 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();
}
//讀寫鎖，當資源處于寫入模式時，其他線程寫入需要等待本次寫入結束之后才能繼續(xù)寫入
static ReaderWriterLockSlim LogWriteLock = new ReaderWriterLockSlim();
static void WriteLog()
{
try
{
//設置讀寫鎖為寫入模式獨占資源，其他寫入請求需要等待本次寫入結束之后才能繼續(xù)寫入
//注意：長時間持有讀線程鎖或寫線程鎖會使其他線程發(fā)生饑餓 (starve)。 為了得到最好的性能，需要考慮重新構造應用程序以將寫訪問的持續(xù)時間減少到最小。
// 從性能方面考慮，請求進入寫入模式應該緊跟文件操作之前，在此處進入寫入模式僅是為了降低代碼復雜度
// 因進入與退出寫入模式應在同一個try finally語句塊內，所以在請求進入寫入模式之前不能觸發(fā)異常，否則釋放次數大于請求次數將會觸發(fā)異常
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
{
//退出寫入模式，釋放資源占用
//注意：一次請求對應一次釋放
// 若釋放次數大于請求次數將會觸發(fā)異常[寫入鎖定未經保持即被釋放]
// 若請求處理完成后未釋放將會觸發(fā)異常[此模式不下允許以遞歸方式獲取寫入鎖定]
LogWriteLock.ExitWriteLock();
}
}
}
運行結果：
使用讀寫鎖，全部日志成功寫入了日志文件。
3.測試復雜多線程環(huán)境下使用讀寫鎖同步寫入文件
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();
}
}
//讀寫鎖，當資源處于寫入模式時，其他線程寫入需要等待本次寫入結束之后才能繼續(xù)寫入
static ReaderWriterLockSlim LogWriteLock = new ReaderWriterLockSlim();
static void WriteLog()
{
try
{
//設置讀寫鎖為寫入模式獨占資源，其他寫入請求需要等待本次寫入結束之后才能繼續(xù)寫入
//注意：長時間持有讀線程鎖或寫線程鎖會使其他線程發(fā)生饑餓 (starve)。 為了得到最好的性能，需要考慮重新構造應用程序以將寫訪問的持續(xù)時間減少到最小。
// 從性能方面考慮，請求進入寫入模式應該緊跟文件操作之前，在此處進入寫入模式僅是為了降低代碼復雜度
// 因進入與退出寫入模式應在同一個try finally語句塊內，所以在請求進入寫入模式之前不能觸發(fā)異常，否則釋放次數大于請求次數將會觸發(fā)異常
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
{
//退出寫入模式，釋放資源占用
//注意：一次請求對應一次釋放
// 若釋放次數大于請求次數將會觸發(fā)異常[寫入鎖定未經保持即被釋放]
// 若請求處理完成后未釋放將會觸發(fā)異常[此模式不下允許以遞歸方式獲取寫入鎖定]
LogWriteLock.ExitWriteLock();
}
}
}
運行結果：
部分日志文件內容：
... Tid: 36 2016年12月11日 15:29:22.825 Tid: 29 2016年12月11日 15:29:22.830 Tid: 6 2016年12月11日 15:29:22.838 Tid: 26 2016年12月11日 15:29:22.845 Tid: 34 2016年12月11日 15:29:22.854 Tid: 24 2016年12月11日 15:29:22.863 Tid: 27 2016年12月11日 15:29:22.872 Tid: 14 2016年12月11日 15:29:22.877 Tid: 23 2016年12月11日 15:29:22.886 Tid: 20 2016年12月11日 15:29:22.892 Tid: 30 2016年12月11日 15:29:22.898 Tid: 9 2016年12月11日 15:29:22.904 Tid: 21 2016年12月11日 15:29:22.909 Tid: 22 2016年12月11日 15:29:22.915 Tid: 7 2016年12月11日 15:29:22.920 Tid: 3 2016年12月11日 15:29:22.925 Tid: 12 2016年12月11日 15:29:22.931 Tid: 5 2016年12月11日 15:29:22.937 Tid: 13 2016年12月11日 15:29:22.942 Tid: 11 2016年12月11日 15:29:22.947 Tid: 19 2016年12月11日 15:29:22.953 Tid: 37 2016年12月11日 15:29:22.958 Tid: 37 2016年12月11日 15:29:22.964 Tid: 40 2016年12月11日 15:29:22.970 Tid: 40 2016年12月11日 15:29:22.975 Tid: 40 2016年12月11日 15:29:22.980 Tid: 40 2016年12月11日 15:29:22.985 Tid: 40 2016年12月11日 15:29:22.991 Tid: 40 2016年12月11日 15:29:22.997 Tid: 31 2016年12月11日 15:29:23.3 Tid: 31 2016年12月11日 15:29:23.9 Tid: 31 2016年12月11日 15:29:23.14 Tid: 31 2016年12月11日 15:29:23.20 Tid: 31 2016年12月11日 15:29:23.27 Tid: 31 2016年12月11日 15:29:23.33 Tid: 31 2016年12月11日 15:29:23.38 Tid: 31 2016年12月11日 15:29:23.44 Tid: 31 2016年12月11日 15:29:23.49 Tid: 31 2016年12月11日 15:29:23.57 Tid: 31 2016年12月11日 15:29:23.63 Tid: 31 2016年12月11日 15:29:23.68 Tid: 31 2016年12月11日 15:29:23.74 Tid: 16 2016年12月11日 15:29:23.80 Tid: 16 2016年12月11日 15:29:23.86 Tid: 16 2016年12月11日 15:29:23.93 Tid: 16 2016年12月11日 15:29:23.99 Tid: 16 2016年12月11日 15:29:23.105 Tid: 16 2016年12月11日 15:29:23.110 Tid: 16 2016年12月11日 15:29:23.116 Tid: 38 2016年12月11日 15:29:23.122 Tid: 38 2016年12月11日 15:29:23.128 Tid: 28 2016年12月11日 15:29:23.134 Tid: 19 2016年12月11日 15:29:23.139 Tid: 25 2016年12月11日 15:29:23.146 Tid: 37 2016年12月11日 15:29:23.152 Tid: 39 2016年12月11日 15:29:23.158 Tid: 32 2016年12月11日 15:29:23.164 Tid: 33 2016年12月11日 15:29:23.170 Tid: 31 2016年12月11日 15:29:23.176 Tid: 35 2016年12月11日 15:29:23.182 Tid: 40 2016年12月11日 15:29:23.189 Tid: 15 2016年12月11日 15:29:23.194 Tid: 18 2016年12月11日 15:29:23.202 Tid: 17 2016年12月11日 15:29:23.208 Tid: 10 2016年12月11日 15:29:23.215 Tid: 16 2016年12月11日 15:29:23.221
復雜多線程環(huán)境下使用讀寫鎖，全部日志成功寫入了日志文件，由ThreadId和DateTime可以看出是由不同的線程同步寫入。
以上就是本文的全部內容，希望本文的內容對大家的學習或者工作能帶來一定的幫助，同時也希望多多支持腳本之家！
相關文章
這篇文章主要介紹了C# Assembly.Load案例詳解,本篇文章通過簡要的案例,講解了該項技術的了解與使用,以下就是詳細內容,需要的朋友可以參考下2021-08-08
這篇文章主要介紹了C$ 筆試題之同線程Lock語句遞歸不會死鎖，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧2020-02-02
下面小編就為大家?guī)硪黄猚# 配置文件App.config操作類庫的方法。小編覺的挺不錯的，現在就分享給大家，也給大家做個參考。一起跟隨小編過來看看吧2016-12-12
這篇文章主要介紹了c#深拷貝文件夾示例,需要的朋友可以參考下2014-04-04
本文主要介紹了C#快速實現IList非泛型類接口的自定義類作為數據源，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧2023-02-02
這篇文章主要介紹了使用C#語言實現的查詢條件界面展開和收起功能的完美解決方案,需要的朋友可以參考下2016-11-11
在C#語句中,將using關鍵字作為一個語句時,該語句的作用是定義一個用大括號規(guī)定的范圍,在該范圍的末尾,系統會立即釋放using后小括號內指定的對象,下面這篇文章主要給大家介紹了關于C#中using關鍵字使用的相關資料,需要的朋友可以參考下2022-06-06
本文主要分享了C#刪除字符串中的中文的具體實例，具有一定的參考價值，需要的朋友一起來看下吧2016-12-12
這篇文章主要介紹了c# 使用特定帳號密碼訪問Windows網路共享的方法，幫助大家更好的理解和學習使用c#，感興趣的朋友可以了解下2021-03-03
C# WinForm調用Shell_NotifyIcon的示例代碼
這篇文章主要介紹了C# WinForm調用Shell_NotifyIcon的示例代碼，幫助大家更好的理解和使用c#，感興趣的朋友可以了解下2020-11-11