c#實現每隔一段時間執行程式碼(多執行緒)
阿新 • • 發佈:2020-08-08
方法一:呼叫執行緒執行方法,在方法中實現死迴圈,每個迴圈Sleep設定時間;
方法二:使用System.Timers.Timer類;
方法三:使用System.Threading.Timer;
using System; using System.Collections; using System.Threading; public class Test { public static void Main() { Test obj = new Test(); Console.WriteLine(Thread.CurrentThread.ManagedThreadId.ToString()); //方法一:呼叫執行緒執行方法,在方法中實現死迴圈,每個迴圈Sleep設定時間 Thread thread = new Thread(new ThreadStart(obj.Method1)); thread.Start(); //方法二:使用System.Timers.Timer類 System.Timers.Timer t = new System.Timers.Timer(100);//例項化Timer類,設定時間間隔 t.Elapsed += new System.Timers.ElapsedEventHandler(obj.Method2);//到達時間的時候執行事件 t.AutoReset = true;//設定是執行一次(false)還是一直執行(true) t.Enabled = true;//是否執行System.Timers.Timer.Elapsed事件 while (true) { Console.WriteLine("test_" + Thread.CurrentThread.ManagedThreadId.ToString()); Thread.Sleep(100); } //方法三:使用System.Threading.Timer //Timer建構函式引數說明: //Callback:一個 TimerCallback 委託,表示要執行的方法。 //State:一個包含回撥方法要使用的資訊的物件,或者為空引用(Visual Basic 中為 Nothing)。 //dueTime:呼叫 callback 之前延遲的時間量(以毫秒為單位)。指定 Timeout.Infinite 以防止計時器開始計時。指定零 (0) 以立即啟動計時器。 //Period:呼叫 callback 的時間間隔(以毫秒為單位)。指定 Timeout.Infinite 可以禁用定期終止。 System.Threading.Timer threadTimer = new System.Threading.Timer(new System.Threading.TimerCallback(obj.Method3), null, 0, 100); while (true) { Console.WriteLine("test_" + Thread.CurrentThread.ManagedThreadId.ToString()); Thread.Sleep(100); } Console.ReadLine(); } void Method1() { while (true) { Console.WriteLine(DateTime.Now.ToString() + "_" + Thread.CurrentThread.ManagedThreadId.ToString()); Thread.CurrentThread.Join(100);//阻止設定時間 } } void Method2(object source, System.Timers.ElapsedEventArgs e) { Console.WriteLine(DateTime.Now.ToString() + "_" + Thread.CurrentThread.ManagedThreadId.ToString()); } void Method3(Object state) { Console.WriteLine(DateTime.Now.ToString() + "_" + Thread.CurrentThread.ManagedThreadId.ToString()); } }
個人測試例項:
using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.Threading; using System.Threading.Tasks; namespace Test001 { public class Test { public static void Main(string[] args) { Test obj = new Test(); #region 方法一:呼叫執行緒執行方法,在方法中實現死迴圈,每個迴圈Sleep設定時間 ////方法一:呼叫執行緒執行方法,在方法中實現死迴圈,每個迴圈Sleep設定時間 ////Console.WriteLine(Thread.CurrentThread.ManagedThreadId.ToString()); //列印當前執行緒ID //Thread thread = new Thread(new ThreadStart(obj.Method1)); //thread.Start(); #endregion #region 方法二:使用System.Timers.Timer類 ////方法二:使用System.Timers.Timer類 //System.Timers.Timer t = new System.Timers.Timer(1000 * 10);//例項化Timer類,設定時間間隔 //t.Elapsed += new System.Timers.ElapsedEventHandler(obj.Method2);//到達時間的時候執行事件 //t.AutoReset = true;//設定是執行一次(false)還是一直執行(true) //t.Enabled = true;//是否執行System.Timers.Timer.Elapsed事件 //while (true) //{ // // Console.WriteLine("test_" + Thread.CurrentThread.ManagedThreadId.ToString()); // Thread.Sleep(1000); //} #endregion #region 方法三:使用System.Threading.Timer //方法三:使用System.Threading.Timer //Timer建構函式引數說明: //Callback:一個 TimerCallback 委託,表示要執行的方法。 //State:一個包含回撥方法要使用的資訊的物件,或者為空引用(Visual Basic 中為 Nothing)。 //dueTime:呼叫 callback 之前延遲的時間量(以毫秒為單位)。指定 Timeout.Infinite 以防止計時器開始計時。指定零 (0) 以立即啟動計時器。 //Period:呼叫 callback 的時間間隔(以毫秒為單位)。指定 Timeout.Infinite 可以禁用定期終止。 System.Threading.Timer threadTimer1 = new System.Threading.Timer(new System.Threading.TimerCallback(obj.Method3), null, 0, 1000 * 10); //while (true) //{ // //Console.WriteLine("test_" + Thread.CurrentThread.ManagedThreadId.ToString()); // Thread.Sleep(1000); //} System.Threading.Timer threadTimer2 = new System.Threading.Timer(new System.Threading.TimerCallback(obj.Method4), null, 0, 1000); while (true) { //Console.WriteLine("test_" + Thread.CurrentThread.ManagedThreadId.ToString()); Thread.Sleep(1000); } #endregion #region c#(asp.net) 多執行緒示例,用於同時處理多個任務 //Thread Thread1 = new Thread(new ThreadStart(CalcSum)); //Thread Thread2 = new Thread(new ThreadStart(CalcGap)); //Thread1.Start(); //Thread2.Start(); //Thread1.Join(); //Thread2.Join(); //Console.ReadLine(); #endregion } #region /// <summary> /// Method1 /// </summary> void Method1() { while (true) { #region 寫log日誌 string filename = "F:\\ThreadTest1.txt"; //txt檔案路徑 bool flag = false; //標記是否是新建檔案的標量 if (!System.IO.File.Exists(filename)) //如果檔案不存在,就新建該檔案 { flag = true; System.IO.StreamWriter sr = System.IO.File.CreateText(filename); sr.Close(); } //向檔案寫入內容 System.IO.StreamWriter x = new System.IO.StreamWriter(filename, true, System.Text.Encoding.Default); if (flag) x.Write("測試開始:" + "\r\n"); x.WriteLine(DateTime.Now.ToString() + "\r\n"); x.Close(); #endregion Console.WriteLine(DateTime.Now.ToString() + "_" + Thread.CurrentThread.ManagedThreadId.ToString()); Thread.CurrentThread.Join(1000);//阻止設定時間 } } /// <summary> /// Method2 /// </summary> /// <param name="source"></param> /// <param name="e"></param> void Method2(object source, System.Timers.ElapsedEventArgs e) { #region 寫log日誌 string filename = "F:\\ThreadTest2.txt"; //txt檔案路徑 bool flag = false; //標記是否是新建檔案的標量 if (!System.IO.File.Exists(filename)) //如果檔案不存在,就新建該檔案 { flag = true; System.IO.StreamWriter sr = System.IO.File.CreateText(filename); sr.Close(); } //向檔案寫入內容 System.IO.StreamWriter x = new System.IO.StreamWriter(filename, true, System.Text.Encoding.Default); if (flag) x.Write("測試開始:" + "\r\n"); x.WriteLine(DateTime.Now.ToString() + "\r\n"); x.Close(); #endregion Console.WriteLine(DateTime.Now.ToString() + "_" + Thread.CurrentThread.ManagedThreadId.ToString()); } /// <summary> /// Method3 /// </summary> /// <param name="state"></param> void Method3(Object state) { #region 寫log日誌 string filename = "F:\\ThreadTest3.txt"; //txt檔案路徑 bool flag = false; //標記是否是新建檔案的標量 if (!System.IO.File.Exists(filename)) //如果檔案不存在,就新建該檔案 { flag = true; System.IO.StreamWriter sr = System.IO.File.CreateText(filename); sr.Close(); } //向檔案寫入內容 System.IO.StreamWriter x = new System.IO.StreamWriter(filename, true, System.Text.Encoding.Default); if (flag) x.Write("測試開始:" + "\r\n"); x.WriteLine(DateTime.Now.ToString() + "\r\n"); x.Close(); #endregion Console.WriteLine("Method3___" + DateTime.Now.ToString() + "_" + Thread.CurrentThread.ManagedThreadId.ToString()); } /// <summary> /// Method4 /// </summary> /// <param name="state"></param> void Method4(Object state) { #region 寫log日誌 string filename = "F:\\ThreadTest4.txt"; //txt檔案路徑 bool flag = false; //標記是否是新建檔案的標量 if (!System.IO.File.Exists(filename)) //如果檔案不存在,就新建該檔案 { flag = true; System.IO.StreamWriter sr = System.IO.File.CreateText(filename); sr.Close(); } //向檔案寫入內容 System.IO.StreamWriter x = new System.IO.StreamWriter(filename, true, System.Text.Encoding.Default); if (flag) x.Write("測試開始:" + "\r\n"); x.WriteLine(DateTime.Now.ToString() + "\r\n"); x.Close(); #endregion Console.WriteLine("Method4_" + DateTime.Now.ToString() + "_" + Thread.CurrentThread.ManagedThreadId.ToString()); } //求和方法 protected static void CalcSum() { #region 寫log日誌 string filename = "F:\\CalcSum.txt"; //txt檔案路徑 bool flag = false; //標記是否是新建檔案的標量 if (!System.IO.File.Exists(filename)) //如果檔案不存在,就新建該檔案 { flag = true; System.IO.StreamWriter sr = System.IO.File.CreateText(filename); sr.Close(); } //向檔案寫入內容 System.IO.StreamWriter x = new System.IO.StreamWriter(filename, true, System.Text.Encoding.Default); if (flag) x.Write("測試開始:" + "\r\n"); x.WriteLine(DateTime.Now.ToString() + "\r\n"); x.Close(); Console.WriteLine(DateTime.Now.ToString() + "_" + Thread.CurrentThread.ManagedThreadId.ToString()); System.Threading.Thread.Sleep(5000); #endregion #region //long sum = 0; //for (long i = 0; i < 100; i++) //{ // sum += i; // Response.Write(string.Format("Thread1-->i={0}:sum={1}<br/>", i, sum)); // Response.Flush(); // System.Threading.Thread.Sleep(5000); //} #endregion } //求差方法 protected static void CalcGap() { #region 寫log日誌 string filename = "F:\\CalcGap.txt"; //txt檔案路徑 bool flag = false; //標記是否是新建檔案的標量 if (!System.IO.File.Exists(filename)) //如果檔案不存在,就新建該檔案 { flag = true; System.IO.StreamWriter sr = System.IO.File.CreateText(filename); sr.Close(); } //向檔案寫入內容 System.IO.StreamWriter x = new System.IO.StreamWriter(filename, true, System.Text.Encoding.Default); if (flag) x.Write("測試開始:" + "\r\n"); x.WriteLine(DateTime.Now.ToString() + "\r\n"); x.Close(); Console.WriteLine(DateTime.Now.ToString() + "_" + Thread.CurrentThread.ManagedThreadId.ToString()); System.Threading.Thread.Sleep(1000); #endregion #region //long gap = 0; //for (long i = 100; i >= 0; i--) //{ // gap = i - 1; // Response.Write(string.Format("Thread2-->i={0}:gap={1}<br/>", i, gap)); // Response.Flush(); // System.Threading.Thread.Sleep(1000); //} #endregion } #endregion } }