using System.Data.Common;
using System.Data.SqlClient;
using System.Transactions;
using System.Threading;
class Program {
   static string sCnx =
         "server = localhost ; uid=sa ; pwd =; database = ORGANIZATION";
   static string sCmd1 =
         "INSERT INTO DEPARTMENTS VALUES ('COM','Communication')";
   static string sCmd2 =
    "INSERT INTO EMPLOYEES VALUES ('COM','Smith','Adam','(123) 456-7899')";
   static void Main() {
      try {
         using (TransactionScope txScope = new TransactionScope()) {
            using (SqlConnection cnx = new SqlConnection(sCnx)) {
               cnx.Open();
               DbCommand cmd = new SqlCommand(sCmd1, cnx);
               cmd.ExecuteNonQuery();
               DependentTransaction depTx =
                  Transaction.Current.DependentClone (
                     DependentCloneOption.BlockCommitUntilComplete );
               ThreadPool.QueueUserWorkItem( AsyncProc, depTx);
               txScope.Complete();
            } // end using cnx.
         } //end using txScope 'ITransaction.Commit()' is called here. 
      } catch { }
   }
   static void AsyncProc(object state) {
     DependentTransaction depTx = state as DependentTransaction;
      try {
         using ( SqlConnection cnx = new SqlConnection( sCnx ) ) {
            cnx.Open();
            cnx.EnlistTransaction( depTx );
            DbCommand cmd = new SqlCommand( sCmd2, cnx );
            cmd.ExecuteNonQuery();
            depTx.Complete();
         } // end using cnx.
      } catch {
         depTx.Rollback();
      }
   }
}