快捷導(dǎo)航

C#在驗(yàn)證文件共享模式下實(shí)現(xiàn)多線程文件寫入

更新時間：2024年01月04日 08:39:21 作者：rjcql

這篇文章主要為大家詳細(xì)介紹了C#在驗(yàn)證文件共享模式下實(shí)現(xiàn)多線程文件寫入的相關(guān)知識,文中的示例代碼講解詳細(xì),感興趣的小伙伴可以了解下

寫在前面

原以為設(shè)置了文件共享模式為允許隨后寫入(FileShare.Write)，就可以實(shí)現(xiàn)多線程下的正常寫入操作，實(shí)際情況是使用該模式后不會報線程獨(dú)占問題，但是寫入的內(nèi)容是不完整的，比如開了n個線程，真正寫入的內(nèi)容不僅時序上不連續(xù)，且內(nèi)容也不完整；還是需要額外加鎖后才能保證時序及內(nèi)容的完整性。

代碼實(shí)現(xiàn)

using System.Text;
 
public class Program
{
    static int SuccessCount = 0;
    static int FailureCount = 0;
    static ReaderWriterLockSlim WriteLock = new ReaderWriterLockSlim();
    static object Lock = new object();
 
    static void Main(string[] args)
    {
 
        Console.WriteLine("Hello, World!");
 
        var result = Parallel.For(0, 30, action =>
        {
            WriteTest();
        });
 
        Console.WriteLine("寫入中...");
        Console.ReadLine();
    }
 
    static void WriteTest()
    {
        try
        {
            WriteLock.EnterWriteLock();
            //lock (Lock)
            //{
                using (FileStream logFile = new FileStream("test.txt", FileMode.OpenOrCreate, FileAccess.Write, FileShare.Write))
                {
                    SuccessCount++;
                    Console.WriteLine("count:" + SuccessCount);
                    var count = SuccessCount;
                    var logContentBytes = Encoding.Default.GetBytes($"{Thread.CurrentThread.ManagedThreadId}, {DateTime.Now.ToString("yyyy-MM-dd:HH:mm:ss:ffff")},{count},{Environment.NewLine}");
                    logFile.Seek(0, SeekOrigin.End);
                    logFile.Write(logContentBytes, 0, logContentBytes.Length);
                }
            //}
        }
        catch (Exception ex)
        {
            FailureCount++;
            Console.WriteLine($"Failure Count:{FailureCount}");
        }
        finally { WriteLock.ExitWriteLock(); }
    }
 
}