从 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,缓慢的部分应该按照我展示的方式隔离,而不是用它污染应用程序。
我们有一个 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,缓慢的部分应该按照我展示的方式隔离,而不是用它污染应用程序。