public static void th_fct(Mon_DataSet DataSet_) { //Console.ReadLine(); Console.WriteLine("On est dans le thread Intraday"); //Program.ma_db_intraday.Init_Base("Base_Intraday"); //BI.Init_Tables(Program.ibd); //try //{ foreach (DataTable DataTable_ in DataSet_.Tables) { Console.WriteLine("J'ai été appelé par {0}", Thread.CurrentThread.Name); //DataSet_.EnregistreLaTable(DataTable_.TableName); //DataSet_.Aff_Enr_Colonnes(DataTable_, false); Program.ma_db_intraday.Remplit_Table_moyenne(Program.ibd, DataTable_.TableName, DataTable_.Columns["prix"], DataTable_.Columns["VOLUME"]); } //} //catch (Exception e) //{ //Console.WriteLine("Erreur dans Threadloop:{0}", e.Message); //} } public static void Main() { Mon_DataSet essai; /*Timer pour le remplissage de la base intraday*/ Thread th; t_ref = new TimeSpan(0,0,1); ma_db_intraday = new Ma_Base_Intraday(); ma_db_intraday.Efface_BD(ibd); ma_db_intraday.Init_Base(ibd); bool Bd_Int_Prete = false ; bool List_Init = false; TimeSpan tt = new TimeSpan(0, 0, 0); Console.WriteLine("Entrez le chemin du fichier excel source:"); chemin = Console.ReadLine(); essai = new Mon_DataSet(); ma_db_intraday = new Ma_Base_Intraday(); /*enregistrer les derniers volumes dans les tables*/ List_Vol = new tab_volume(); for (int i =1;i<200;i++) { try { DateTime t = DateTime.Now; Stopwatch sw = new Stopwatch(); sw.Start(); essai.RemplirAPartirdExcel(chemin, DateTime.Now); Console.WriteLine("moi aussi !!"); foreach (DataTable DataTable_ in essai.Tables) { if (!List_Init) { List_Vol.Ajouter_Elt(DataTable_.TableName, 0); } //essai.EnregistreLaTable(DataTable_.TableName); } //List_Vol.affiche_list(); List_Init = true; sw.Stop(); ma_db_intraday.SetSource(essai); if (!Bd_Int_Prete) { Bd_Int_Prete = ma_db_intraday.Init_Tables(ibd); } Console.WriteLine("le remplissage du dataset a mis:{0}", sw.Elapsed); tt = tt + DateTime.Now.Subtract(t); if (tt >= t_ref) { Console.WriteLine("Une seconde s'est ecoulée"); tt = new TimeSpan(0, 0, 0); //Mon_DataSet nouveau = new Mon_DataSet(); // //nouveau = essai; //essai.Dispose(); Thread_Intraday th_intraday = new Thread_Intraday(ref essai); //essai.Dispose(); //essai = new Mon_DataSet(); //ma_db_intraday = null; th = new Thread(delegate() { th_fct(essai); }); //th = new Thread(new ThreadStart(th_intraday.ThreadLoop)); //essai = new Mon_DataSet(); th.Name = "alter" + DateTime.Now.ToString(); th.Start(); essai = new Mon_DataSet(); }