static void RunPackage( int NumFlowsExecute
                              , int NumRepetition
                              , int NumSession
                              , object SourceDataList
                              , string DTSXPackage
                              , string StageDBName
                              , string DWHDBName
                              , ref Boolean ExceptionFlow)
        {
            Application app = new Application();
            Package pkg = app.LoadPackage(DTSXPackage, null);
            Variables vars = pkg.Variables;
                      vars["User::NumFlowsExecute"].Value = NumFlowsExecute;
                      vars["User::SourceDataList"].Value = SourceDataList;
                      vars["User::NumRepetition"].Value = NumRepetition;
                      vars["User::NumSession"].Value = NumSession;
                      vars["User::StageDBName"].Value = StageDBName;
                      vars["User::DWHDBName"].Value = DWHDBName;
             pkg.Execute(null, vars, null, null, null);

            if (pkg.ExecutionResult.ToString() == "Failure")
            {
                ExceptionFlow = true;
            }
        }

var TasksFlow = new List<Thread>();      
.
.
.
                for (int i = 0; i < CountRunFlow; i++)
                {
                    int NumFlowsExecute = i + 1;
                    var Thread = new Thread(() => RunPackage(NumFlowsExecute
                                                           , NumRepetition
                                                           , NumSession
                                                           , DTableList
                                                           , DTSXPackage
                                                           , StageDBName
                                                           , DWHDBName
                                                           , ref ExceptionFlow));
                    Thread.Start();
                    TasksFlow.Add(Thread);
                }

            while( TasksFlow.Any(t => t.ThreadState == System.Threading.ThreadState.Running))
            {
                CounterSec ++;

                // поток(и) выполняется дольше допустимого времени (сек)
                if( CounterSec > TimeOutDTSXPackage) 
                  {
                   
                    for ( int i = 0; i < CountRunFlow; i ++)
                       {
                         var CurrentThread = TasksFlow.ElementAt(i);
                         // проверка состояния потока
                         if( CurrentThread.ThreadState == System.Threading.ThreadState.Running)
                           {
                             CurrentThread.Abort(); //если активен, то завершаем поток
                           }
                       }
                  }
                Thread.Sleep(1000);
            }

            Dts.Variables["User::ExceptionFlow"].Value = ExceptionFlow;
            Dts.TaskResult = (int)ScriptResults.Success;