我最近偶然发现了这个奇怪的错误。在我的方法完成所有异步任务之前,看起来我的一个对象正在处理。但是我们来看看吧。
我有那种种子我的数据库的异步方法。它在Startup
方法中被称为Configure
类。
private void InitDatabase(IApplicationBuilder app) {
using (var scope = app.ApplicationServices.CreateScope()) {
var services = scope.ServiceProvider;
try {
var context = services.GetRequiredService<GrabGoContext>();
new DatabaseInitializer().InitializeAsync(context,
services.GetService(typeof(UserManager<User>)) as UserManager<User>,
services.GetService(typeof(SignInManager<User>)) as SignInManager<User>,
services.GetService(typeof(RoleManager<IdentityRole<int>>)) as RoleManager<IdentityRole<int>>,
_logger).Wait();
_logger.LogDebug("Database initialization finished.");
}
catch (Exception ex) {
_logger.LogError(ex, "An error occurred while seeding the database.");
if (Debugger.IsAttached) Debugger.Break();
}
}
}
而那个来自DatabaseInitializer
类的方法:
public async Task InitializeAsync(GrabGoContext context,
UserManager<User> userManager,
SignInManager<User> signInManager,
RoleManager<IdentityRole<int>> roleManager,
ILogger<Startup> logger) {
if(IsDatabaseInialized) return;
IsDatabaseInialized = true;
await context.Database.EnsureCreatedAsync();
await AddStores(context);
await AddProducts(context);
await AddRoles(roleManager)
.ContinueWith(t => AddRolesToUsers(userManager)); // <- Here throws exception "System.ObjectDisposedException" for object `userManager`
await AddUsers(userManager);
await context.SaveChangesAsync();
}
问题是,如果我使用ContinueWith
链接任务,它会在System.ObjectDisposedException
对象上抛出userManager
。但我需要使用ContinueWith
,因为在我将用户分配给该角色之前我需要Roles
。
我的方法负责添加角色
private async Task AddRoles(RoleManager<IdentityRole<int>> roleManager) {
if (await roleManager.Roles.AnyAsync()) return;
var roles = (List<IdentityRole<int>>) new RolesListExample().GetExamples();
foreach (var role in roles) {
var result = await roleManager.CreateAsync(role);
if(!result.Succeeded) throw new ApplicationException("Erros while adding roles: " +
JsonConvert.SerializeObject(result.Errors));
}
}
private async Task AddRolesToUsers(UserManager<User> userManager) {
var registerModels = (List<RegisterModel>)new RegisterListRequestExample().GetExamples();
foreach(var registerModel in registerModels) {
var user = await userManager.FindByEmailAsync(registerModel.Email);
var result = await userManager.AddToRoleAsync(user, registerModel.Role.ToString());
if(!result.Succeeded)
throw new ApplicationException("Erros while adding roles to user: " +
JsonConvert.SerializeObject(result.Errors));
}
}
还有我的RolesListExample
课程:
public class RolesListExample : IExamplesProvider {
/// <inheritdoc />
public object GetExamples() {
var roles = new List<IdentityRole<int>>();
foreach (var availableRole in (AvailableRoles[]) Enum.GetValues(typeof(AvailableRoles))) {
roles.Add(new IdentityRole<int>(availableRole.ToString()));
}
return roles;
}
}
我的问题是:
为什么在完成所有任务之前我的对象处理?
我认为这是因为using
。另外我发现Question,但没有为我澄清情况。
@Update
正如@PanagiotisKanavos所建议的,我删除了using
声明,它解决了我的处置问题。谢谢!
您正在等待任务的继续。代替:
await AddRoles(roleManager).ContinueWith(t => AddRolesToUsers(userManager));
...尝试:
var task1 = AddRoles(roleManager);
var task2 = task1.ContinueWith(t => AddRolesToUsers(userManager));
await task1;
await task2;