异步查询和保存(EF6+)
这个特性从EF6开始,在之前的版本中不存在.
让客户满意是我们工作的目标,不断超越客户的期望值来自于我们对这个行业的热爱。我们立志把好的技术通过有效、简单的方式提供给客户,将通过不懈努力成为客户在信息化领域值得信任、有价值的长期合作伙伴,公司提供的服务项目有:域名注册、网站空间、营销软件、网站建设、连山网站维护、网站推广。
EF6(.net 4.5)开始支持用async和await关键字进行异步查询和保存,不是所有的程序都能从异步中得到好处,当被挂起长时间的运行,网络或IO-bound任务,可以被用于提高客户端的响应和服务端的扩展,
什么时侯适合使用asyn
创建model
创建异步程序
让程序异步
结论
什么时侯适合使用asyn
这篇文章的目的是用一种方式介绍asyn概念,让它很容易被观察到异步和同步程序之间的区别,这个演练不关注异步编程带来好处的任何场景。
异步操作通常用于执行完成时间可能较长的任务,如打开大文件、连接远程计算机或查询数据库。异步操作在主应用程序线程以外的线程中执行。应用程序调用方法异步执行某个操作时,应用程序可在异步方法执行其任务时继续执行。
在客户端程序(WinForm, WPF等)中,在当前的线程执行时异步操作可用于保持UI的响应。在服务端程序中(ASP.NET等)异步线程可以被用于处理其它未来的请求 - 这是可以减少内存的使用量或增加服务器的吞吐量。
在多数的程序中使用异步没有明显的好处,甚至是有害的。使用测试,分析和通用场景来测量在你的特定的情况下的影响。
Create the model
创建控制台程序AsyncDemo
添加EntityFramework Nuget package
安装EntityFramework package
创建Model - AsyncDemo.cs:
using System.Collections.Generic; using System.Data.Entity; namespace AsyncDemo { public class BloggingContext : DbContext { public DbSetBlogs { get; set; } public DbSet Posts { get; set; } } public class Blog { public int BlogId { get; set; } public string Name { get; set; } public virtual List Posts { get; set; } } public class Post { public int PostId { get; set; } public string Title { get; set; } public string Content { get; set; } public int BlogId { get; set; } public virtual Blog Blog { get; set; } } }
创建一个异步程序
class Program { static void Main(string[] args) { PerformDatabaseOperations(); Console.WriteLine(); Console.WriteLine("Quote of the day"); Console.WriteLine("Don't worry about the world coming to an end today... "); Console.WriteLine("It's already tomorrow in Australia."); Console.WriteLine(); Console.WriteLine("Press any key to exit..."); Console.ReadKey(); } public static void PerformDatabaseOperations() { using (var db = new BloggingContext()) { // Create a new blog and save it db.Blogs.Add(new Blog { Name = "Test Blog #" + (db.Blogs.Count() + 1) }); db.SaveChanges(); // Query for all blogs ordered by name var blogs = (from b in db.Blogs orderby b.Name select b).ToList(); // Write all blogs out to Console Console.WriteLine(); Console.WriteLine("All blogs:"); foreach (var blog in blogs) { Console.WriteLine(" " + blog.Name); } } } }
PerformDatabaseOperations方法会保存一个新的Blog到数据库并且获取所有的Blogs然后打印在控制台中。
修改为异步
//添加Tasks引用 using System.Data.Entity; using System.Threading.Tasks; static void Main(string[] args) { var task = PerformDatabaseOperations(); Console.WriteLine("Quote of the day"); Console.WriteLine(" Don't worry about the world coming to an end today... "); Console.WriteLine(" It's already tomorrow in Australia."); task.Wait(); Console.WriteLine(); Console.WriteLine("Press any key to exit..."); Console.ReadKey(); } public static async Task PerformDatabaseOperations() { using (var db = new BloggingContext()) { // Create a new blog and save it db.Blogs.Add(new Blog { Name = "Test Blog #" + (db.Blogs.Count() + 1) }); Console.WriteLine("Calling SaveChanges."); await db.SaveChangesAsync(); Console.WriteLine("SaveChanges completed."); // Query for all blogs ordered by name Console.WriteLine("Executing query."); var blogs = await (from b in db.Blogs orderby b.Name select b).ToListAsync(); // Write all blogs out to Console Console.WriteLine("Query completed with following results:"); foreach (var blog in blogs) { Console.WriteLine(" - " + blog.Name); } } }
原文:https://msdn.microsoft.com/en-us/data/jj819165.aspx
当前标题:异步查询和保存(EF6+)
网页路径:http://azwzsj.com/article/goedcj.html