我有一个实体框架方法,它只是将 a 添加Product
到数据库中。当我运行我的测试方法时,这一切都按预期工作。
然后我有一个AddProductAsync
方法:
Task<Product> AddProductAsync(Product pToAdd)
{
return Task<Product>.Factory.StartNew(() => AddProduct(pToAdd));
}
当我使用这种方法运行测试时,测试运行但实际上没有任何反应。我的方法中的断点AddProduct
永远不会被击中,并且没有任何内容添加到数据库中。没有错误,没有警告。
我究竟做错了什么?还是我应该等待EF6?
提前致谢
原始方法:
public static Product AddProduct(Product pToAdd)
{
using (var viralDatabase = new ViralWearContext())
{
if (viralDatabase.Products.Any(p => p.Name == pToAdd.Name || p.Description == pToAdd.Description))
{
var result = viralDatabase.Products.First(p => p.Name == pToAdd.Name || p.Description == pToAdd.Description);
//set 0 so client knows it already exists
result.ProductID = 0;
return result;
}
else
{
var result = viralDatabase.Products.Add(pToAdd);
viralDatabase.SaveChanges();
return result;
}
}
}
单元测试调用的方法:
public async void AddProductsAsyncTest()
{
Stopwatch timer = new Stopwatch();
Product testProduct = GenerateTestProduct();
Product testProductTwo = GenerateTestProduct();
Product testProductThree = GenerateTestProduct();
timer.Start();
Product_Datalayer.AddProduct(testProduct);
Product_Datalayer.AddProduct(testProductTwo);
Product_Datalayer.AddProduct(testProductThree);
var time1 = timer.ElapsedMilliseconds;
Console.WriteLine(timer.ElapsedMilliseconds.ToString());
timer.Reset();
Product testProductAsync = GenerateTestProduct();
Product testProductTwoAsync = GenerateTestProduct();
Product testProductThreeAsync = GenerateTestProduct();
timer.Start();
var result1 = Product_Datalayer.AddProductAsync(testProductAsync);
var result2 = Product_Datalayer.AddProductAsync(testProductTwoAsync);
var result3 = Product_Datalayer.AddProductAsync(testProductThreeAsync);
await Task.WhenAll(result1, result2, result3);
var time2 = timer.ElapsedMilliseconds;
Console.WriteLine(timer.ElapsedMilliseconds.ToString());
}