1. 程式人生 > 實用技巧 >c#實現每隔一段時間執行程式碼(多執行緒)

c#實現每隔一段時間執行程式碼(多執行緒)

方法一:呼叫執行緒執行方法,在方法中實現死迴圈,每個迴圈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
 
    }
}