OperationBrocker.cs

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Collections.Concurrent;
using sage.ew.interficies;
using System.Diagnostics;
using sage.ew.db;

namespace sage.addons.rgpd.Negocio
{
    internal class OperationBroker
    {
        ConcurrentQueue<IOperacion> _lisOperaciones = new ConcurrentQueue<IOperacion>();

        public void _AddOperacion(IOperacion toOperacion)
        {
            _lisOperaciones.Enqueue(toOperacion);
        }

        public void _EjecutarOperaciones()
        {
            Stopwatch loTimer = new Stopwatch();
            loTimer.Start();

            var sbQuerySql = new StringBuilder();

            Trace.WriteLineIf(Debugger.IsAttached, "Lista con " + _lisOperaciones.Count + " operaciones ");

            IOperacion loOperacion;
            while (_lisOperaciones.TryDequeue(out loOperacion))
            {
                if (loOperacion is IQueryOperacion)
                    sbQuerySql.Append(((IQueryOperacion)loOperacion)._GetQuery());
                else //Si no es de la variante query la ejecuto 
                    loOperacion._Execute();
            }

            //Llegados a este punto ya tengo el query... hago un task de 'fire and forget' ya que no puedo hacer nada si falla. 
            var queryString = sbQuerySql.ToString();
            if (!string.IsNullOrWhiteSpace(queryString)) //Sino hay nada 
            {
                System.Threading.Tasks.Task loTask = new System.Threading.Tasks.Task(() => DB.SQLExec(queryString));
                loTask.Start();
                loTask.Wait();
            }

            loTimer.Stop();
            Trace.WriteLineIf(Debugger.IsAttached, "Ejecución finalizada " + loTimer.Elapsed.TotalMilliseconds.ToString());
        }
    }
}