任何并发问题与我的代码

本文关键字：我的 代码 问题 并发 任何 | 更新日期: 2023-09-27 18:03:13

我正在尝试创建一个线程安全的方法。

有没有人看到以下代码的并发性问题?

对我来说似乎很好，虽然我从来没有找到一种方法来测试这个方法的并发性。任何帮助都将是感激的。

   //static locker for thread synchronization
   private static readonly System.Object _object3 = new System.Object();
   //this method needs to be thread-safe
   public static void LogToTextFile(string logMessage, LogLevel logType)
    {
       //make sure only one thread executes this file writing code at a time            
       lock (_object3)
        {
            using (StreamWriter w = File.AppendText(@"c:'logs'log1.txt");
            {
                w.WriteLine("'r'n{0} logged at {1} {2} : {3}", logType.ToString().ToUpper(), DateTime.Now.ToLongTimeString(), DateTime.Now.ToLongDateString(), logMessage);
            }
        }
    }

任何并发问题与我的代码

这段代码没有并发性问题，因为由于锁语句，您只允许一个线程写入文件。

考虑到您正在围绕一个适当作用域的对象进行lock，我认为您的代码没有并发性问题。

然而，正如millimoose在评论中提到的，您有一个潜在的性能问题。如果两个线程同时尝试LogToTextFile，其中一个将首先获得锁，而另一个将在打开、写入和关闭文件时阻塞。这可能是不可接受的，这取决于你的线程正在做什么。

如果我提到的是一个问题，您将不得不实现一个更复杂的线程安全日志记录器。通常会有一个快速写入日志事件的队列。然后还有另一个线程定期唤醒，并清空队列到磁盘上的文件。

另一个可能更好的解决方案可能是保持文件打开，并使用同步的TextWriter来执行写操作。TextWriter.Synchronized提供了一个围绕TextWriter的线程安全包装器:

对返回包装器的所有写操作都是线程安全的。调用这个方法是为了确保一次只有一个线程可以在返回的textwwriter实例上执行这些方法。

下面是一个简单的实现。注意，这还没有经过测试。

public static class MyLogger
{
    private static TextWriter s_writer;
    // Not thread-safe. Call this before other threads are allowed to call Log.
    public void Open(string filename) {
        s_writer = TextWriter.Synchronized( File.AppendText(filename) );
    }
    // Also not thread-safe.
    public void Close() {
       s_writer.Dispose();
    }
    // Thread-safe.
    public void Log(string logMessage, LogLevel logType) {
        s_writer.WriteLine("'r'n{0} logged at {1} {2} : {3}",
            logType.ToString().ToUpper(), DateTime.Now.ToLongTimeString(),
            DateTime.Now.ToLongDateString(), logMessage);
    }    
}

在这个特定的函数中没有并发性问题。lock语句将适当调节对内部代码的访问。

然而，访问@"c:'logs'log1.txt"仍然存在潜在的并发问题。应用程序的另一部分或同一台机器上的另一个进程可能会尝试在编写代码的同时写入该文件。因此，即使有了这个锁，StreamWriter代码也有可能失败。

没有办法解决这种类型的并发问题。文件系统是一种共享资源，您没有真正的保护能力。相反，您的代码需要接受文件系统访问可能失败并正确处理该后果。

通常在处理日志函数时，我用try / catch包装文件系统访问，并吞下发生的任何异常。否则，您将面临日志功能失败导致应用程序关闭的风险。对于您的情况，这可能是可接受的，也可能是不可接受的。

相关文章：