从 IoC 容器加载重物块 UI

Load Heavy Object from IoC Container blocks the UI

我们有一个 WPF 应用程序(.NET 4.0,由于 Windows Server 2003 和 XP 兼容性而无法更改)使用 BCL 来支持 async/await。 对于 DI 和方面,我们使用 Castle IoC,为了访问 Oracle 数据库,我们使用 NHibernate。我们的问题如下:

我已经实现了一个 UoW 模式,在某些时候,它必须接收一个 ISessionFactory。由于我们使用 async/await,用户调用的第一个业务操作将首次加载 ISessionFactory 单例,由于映射,这可能需要几秒钟(即使我将该信息存储在文件中) 并且,因为 async/await 它将在 UI 上执行,从而阻止应用程序。我想要实现的是在单独的线程上加载 ISessionFactory,试图防止 UI 阻塞。因为第一次加载可能发生在任何屏幕上,在任何给定时间,我相信 IoC 容器应该是放置此逻辑的完美位置,但我无法阻止 UI 阻塞。

这里是正常注册:

    Component.For<ISessionFactory>().UsingFactoryMethod(
        k =>
            Fluently.Configure()
                .Database(
                    () => OracleClientConfiguration.Oracle10.ConnectionString(
                        c => c.Is(k.Resolve<ISifarmaConnectionString>().Value))
#if DEBUG
                    .ShowSql().FormatSql()
#endif
                )
                .Mappings(m => m.FluentMappings.AddFromAssemblyOf<ISifarmaUnitOfWork>())
#if DEBUG
                .ExposeConfiguration(c => c.SetInterceptor(new SqlStatementInterceptor()))
#endif
                .BuildSessionFactory()).LifestyleSingleton(),

这是尝试过的方法(因为我 return 具体类型而不是 Task<ISessionFactory> 我不能在这里等待,这显然用 [=16= 阻塞了 UI ]):

    Component.For<ISessionFactory>().UsingFactoryMethod(
        k =>
        {
            var task =
                Task.Factory.StartNew(
                    () =>
                        Fluently.Configure()
                            .Database(
                                () => OracleClientConfiguration.Oracle10.ConnectionString(
                                    c => c.Is(k.Resolve<ISifarmaConnectionString>().Value))
#if DEBUG
                                .ShowSql().FormatSql()
#endif
                            )
                            .Mappings(m => m.FluentMappings.AddFromAssemblyOf<ISifarmaUnitOfWork>())
#if DEBUG
                            .ExposeConfiguration(c => c.SetInterceptor(new SqlStatementInterceptor()))
#endif
                            .BuildSessionFactory());
            Task.WaitAll(task);
            return task.Result;
        }).LifestyleSingleton(),

有什么方法可以做到这一点而不阻塞 UI? 我还尝试在应用程序启动时创建一个任务,使 container.Resolve<ISessionFactory>() 但如果用户在登录屏幕上足够快,则该对象尚未加载。

您可以简单地存储任务而不是该任务的结果(即 Task<ISessionFactory> 而不是 ISessionFactory)并且 await 该任务只要您需要结果:

Component.For<Task<ISessionFactory>>().UsingFactoryMethod(
    k => Task.Factory.StartNew(
        () =>
            Fluently.Configure()
                .Database(
                    () => OracleClientConfiguration.Oracle10.ConnectionString(
                        c => c.Is(k.Resolve<ISifarmaConnectionString>().Value))
#if DEBUG
                    .ShowSql().FormatSql()
#endif
                )
                .Mappings(m => m.FluentMappings.AddFromAssemblyOf<ISifarmaUnitOfWork>())
#if DEBUG
                .ExposeConfiguration(c => c.SetInterceptor(new SqlStatementInterceptor()))
#endif
                .BuildSessionFactory());
    }).LifestyleSingleton(),

多次等待一个任务并没有错。它只会在任务出错时抛出异常(然后它总是会抛出)。

由于在大多数情况下,任务已经完成,await 将同步继续并提取结果。例如:

using(var session = (await sessionTaskFactory).OpenSession())

您应该做的是为 ISessionFactory 创建一个依赖 Lazy<ISessionFactory> 的代理 class。这个代理可以注入任何需要 ISessionFactory 的人,你可以在初始化期间在后台线程中自己触发 ISessionFactory 的创建:

public class LazySessionFactoryProxy : ISessionFactory
{
    private readonly Lazy<ISessionFactory> factory;

    public LazySessionFactoryProxy(Lazy<ISessionFactory> factory) {
        this.factory = factory;
    }

    public ISession OpenSession() {
        return this.factory.Value.OpenSession();
    }
}

可以这样注册:

var lazy = new Lazy<ISessionFactory>(() => ...);

container.Register(Component.For<ISessionFactory>() 
    .Instance(new LazySessionFactoryProxy(lazy)));

Task.Factory.StartNew(() => lazy.Value);

通过在组合根中创建代理 class,您可以让应用程序的其余部分忽略会话工厂中的性能瓶颈。向每个消费者注入 Lazy<ISessionFactory>Task<ISessionFactory> 意味着您需要对整个应用程序进行彻底的更改(违反 OCP) and means you are leaking implementation details (the fact that your specific session factory is costly to create) out of the abstraction (violation of DIP)。

您甚至可以创建一个 LazySessionFactoryProxy,它会在某些代码调用 OpenSession 时显示等待屏幕,并会在工厂初始化时自动关闭它。有趣的是,这一切都是可能的,而无需更改应用程序中的一行代码;只需更改组合根的接线即可。

请注意,DI 容器不支持 'asynchronous resolves' 的问题,但异步解析根本没有用。构建你的 object graphs should be really fast because injection constructors should be simple,缓慢的部分应该按照我展示的方式隔离,而不是用它污染应用程序。