/*Author:liulei

  *Des:异步编程测试

  *Date:2013-10-29

  */

 using System;

 using System.Collections.Generic;

 using System.Data;

 using System.Data.Common;

 using System.Linq;

 using System.Text;

 using System.Threading;

 using Microsoft.Practices.EnterpriseLibrary.Data;

 namespace AsyncApplication

 {

     class Program

     {

         static void Main(string[] args)

         {

             Console.WriteLine("主程序开始!");

             Func<int> caller = new Func<int>(CreateUser);

             Console.WriteLine("异步开始!");

             IAsyncResult ar = caller.BeginInvoke(new AsyncCallback(CallBackMethod), caller);

             caller.EndInvoke(ar);

             Console.WriteLine("主程序完成!");

         }

         //回调方法

         static void CallBackMethod(IAsyncResult ar)

         {

             Func<int> a = (Func<int>)ar.AsyncState;

             int result = a.EndInvoke(ar);//这样是可以获取异步的返回值，可是进行到这里，回调程序就结束了，不会执行下面程序！

             Console.WriteLine("回调完成!");

         }

         //创建用户

         static int CreateUser()

         {

             Database db = CreateDatabase();

             string sql = "insert into [User] (Name,Password) values (@Name,@Password);select @@identity";

             DbCommand dc = db.GetSqlStringCommand(sql);

             db.AddInParameter(dc, "@Name", DbType.String, "zhaoliang");

             db.AddInParameter(dc, "@Password", DbType.String, "");

             var ob = db.ExecuteScalar(dc);

             return Convert.ToInt16(ob);

         }

         //创建Database

         static Database CreateDatabase()

         {

             Database db = DatabaseFactory.CreateDatabase("ConnectionString");

             return db;

         }

     }

 }