从另一个线程访问单例对象

Question

调用服务方法

我使用ThreadPool.QueueUserWorkItem(o => service.Method(arg1, arg2));

服务有对象“loggingService”，我使用 Spring.Net

私有只读 ILoggingServiceloggingService = ObjectBuilder.GetObjectByName("LoggingService");

'LoggingService' 类是单例的。它将日志信息写入log.txt。

当我尝试在此服务方法中调用loggingService.Info（“test”）时，出现异常：文件正被另一个进程占用。

如何访问loggingService？

Answer 1

您的单例显然是每个线程的。
您将需要某种跨线程传递 LoggingService 的方法。

例如，您可以在原始线程中设置service.loggingService。

或者，您可以配置 Spring.Net 以使其成为非线程本地单例。

请注意，您的 LoggingService 必须是线程安全的，否则您会在运行时遇到奇怪的错误。

Answer 2

我在编写一些使用一堆线程的客户端应用程序时遇到了类似的问题。

基本上，您希望 LoggingService 保留一个内部队列（其访问应通过锁控制），并且每次调用 log 方法时，您只需将消息附加到该队列中。在 log 方法结束时检查队列当前是否正在写入文件，如果没有，则开始写入。

Answer 3

public static class SingletonLoggingService
{
    public static ILoggingService LoggingService = ObjectBuilder.GetObjectByName("LoggingService"); 
}


SingletonLoggingService.LoggingService.Info("Test");

Answer 4

我做到了！

我使用队列和线程：

    internal class LoggingService : ILoggingService {
    private readonly Queue<LogEntry> queue = new Queue<LogEntry>();
    private Thread waiter;

    public LoggingService() {
        waiter = new Thread(AddLogEntry);
        waiter.Start();
    }

    public void Shutdown() {
        try {
            waiter.Abort();
        } catch {}
    }

    public void Error(string s, Exception e) {
        lock (queue) {
            queue.Enqueue(new LogEntry(s, e, LogEntryType.Error));
        }
    }

    public void Warning(string message) {
        lock (queue) {
            queue.Enqueue(new LogEntry(message, LogEntryType.Warning));
        }
    }

    public void Info(string message) {
        lock (queue) {
            queue.Enqueue(new LogEntry(message, LogEntryType.Info));
        }
    }

    private void AddLogEntry(object state) {
        while (true) {
            lock (queue) {
                if (queue.Count > 0) {
                    LogEntry logEntry = queue.Dequeue();
                    switch (logEntry.Type)
                    {
                        case LogEntryType.Error:
                             logWriter.Error(logEntry.Message, logEntry.Exception);
                            break;
                        case LogEntryType.Warning:
                            logWriter.Warning(logEntry.Message);
                            break;
                        case LogEntryType.Info:
                            logWriter.Info(logEntry.Message);
                            break;
                    }
                }
            }
            Thread.Sleep(100);
            if (waiter.ThreadState == ThreadState.Aborted) {
                waiter = null;
                break;
            }
        }
    }
}

我在应用程序末尾调用 Shutdown() ：

        protected override void OnExit(ExitEventArgs e) {
        loggingService.Shutdown();
        base.OnExit(e);
    }