最近遇到一個問題：使用一個Thread.Timer的定時器每隔250毫秒輸出一串?dāng)?shù)據(jù)，與此同時，有其他幾個Task在往數(shù)據(jù)庫更新數(shù)據(jù)，這個過程比較耗時。因此這個數(shù)據(jù)庫操作影響了定時器輸出數(shù)據(jù)的操作，導(dǎo)致輸出數(shù)據(jù)延時了。由此問題寫了一個Demo進行測試:

private void Form1_Load(object sender,EventArgs e)
{
    TimerCallbacl svCallBack=BatchQuerySVData;
    System.Threading.Timer _timer=new System.Threading.Timer(svCallBack,null,0,250);
}

public static async void BatchQuerySVData(object state)
{
    await Task.Run(()=>{
        Console.WriteLine(Index++);
        Thread.Sleep(200);
    });
}

private void button1_Clcik(object sender,EventArgs e)
{
    for(int i=0;i<=2;i++)
    {
        Task.Run(()=>{
            Thread.Sleep(1000*10);
        });
    }
}

如上，當(dāng)一個定時器的Task每250毫秒輸出數(shù)據(jù)時，此時增加一個耗時的點擊事件的Task，當(dāng)頻繁點擊按鈕時，定時器的Task輸出的數(shù)據(jù)會發(fā)生延遲。

由此了解了一下Task及線程池的運行機制：

Task的核心機制包含以下幾個關(guān)鍵組成部分：

1. ‌任務(wù)調(diào)度器（TaskScheduler）‌

   • 默認(rèn)使用線程池任務(wù)調(diào)度器
   • 負(fù)責(zé)任務(wù)的排隊和執(zhí)行
   • 支持工作竊取算法提高CPU利用率

2. ‌狀態(tài)管理‌

   • 維護任務(wù)的生命周期狀態(tài)（Created、WaitingToRun、Running、Completed等）
   • 通過狀態(tài)機管理異步操作的執(zhí)行流程

3. ‌延續(xù)任務(wù)（Continuation）‌

   • 使用ContinueWith或await創(chuàng)建任務(wù)鏈
   • 自動處理任務(wù)間的依賴關(guān)系

4. ‌線程池集成‌

   • 重用線程池線程，避免頻繁創(chuàng)建銷毀線程
   • 動態(tài)調(diào)整線程數(shù)量以適應(yīng)負(fù)載變化

5. ‌異常處理‌

   • 將異常封裝在Task對象中
   • 支持統(tǒng)一的異常捕獲和處理機制

線程池使用隊列機制來管理任務(wù)：

• 全局隊列（Global Queue）：接收所有新提交的任務(wù)
• 本地隊列（Local Queue）：每個工作線程都有自己的本地隊列，用于存放從全局隊列中獲取的任務(wù)

‌任務(wù)處理流程‌

1. ‌任務(wù)提交‌：新任務(wù)進入全局隊列
2. ‌工作線程分配‌：空閑線程從全局隊列獲取任務(wù)執(zhí)行
3. ‌工作竊取（Work Stealing）‌：當(dāng)線程本地隊列為空時，可以從其他線程的本地隊列"竊取"任務(wù)
4. ‌線程管理‌：線程池根據(jù)任務(wù)數(shù)量動態(tài)調(diào)整工作線程數(shù)
5. ‌任務(wù)調(diào)度‌：使用先進先出（FIFO）原則處理隊列中的任務(wù)

這種設(shè)計實現(xiàn)了高效的負(fù)載均衡，避免了線程頻繁創(chuàng)建銷毀的開銷，同時通過工作竊取機制提高了CPU利用率。

由此了解，上述代碼的執(zhí)行延遲的原因可能是：

定時器回調(diào)提交任務(wù)到線程池 → 任務(wù)進入全局隊列 → 線程池分配可用線程執(zhí)行 → 當(dāng)長時間運行的數(shù)據(jù)庫任務(wù)占用所有線程時，新的定時器任務(wù)只能在隊列中等待 → 導(dǎo)致執(zhí)行延遲。

然后進行一些驗證工作：

排除定時器的原因：去掉定時器，使用while(true)不停創(chuàng)建Task，結(jié)果仍然存在延遲問題。

private void Form1_Load(object sender,EventArgs e)
{
    BatchQuerySVData(null);
}

public static async void BatchQuerySVData(object state)
{
   while(true)
   {
       await Task.Run(()=>{
          Console.WriteLine(Index++);
          Thread.Sleep(200);
    });
   }
}

進一步驗證，改用Thread專用線程處理定時任務(wù)

private Thread _timerThread;
private void Form1_Load(object sender, EventArgs e)
{
    _timerThread = new Thread(() =>
    {
        while (true)
        {
            Console.WriteLine(Index++);
            Thread.Sleep(250); // 精確控制間隔
        }
    })
    { IsBackground = true };
    _timerThread.Start();
}

修改后果然沒有延遲問題了。

問題原因總結(jié)：

1.雙重排隊：定時器回調(diào)本身就是在線程池處理，內(nèi)部又使用Task.Run創(chuàng)建了另一個線程池任務(wù)

2.線程饑餓：長時間運行的數(shù)據(jù)庫任務(wù)（10秒）占用線程池線程，導(dǎo)致定時器任務(wù)無法及時獲取線程，且存在大量高并發(fā)任務(wù)提交影響程序性能和響應(yīng)能力。

3.線程切換開銷：頻繁創(chuàng)建短生命周期任務(wù)引發(fā)線程切換開銷增大，后續(xù)任務(wù)排隊等待。

4.隊列堆積：當(dāng)線程池所有線程都被長時間任務(wù)占用時，新的定時器任務(wù)只能在隊列中等待。

到此這篇關(guān)于C# Task.Run使用問題解決的文章就介紹到這了,更多相關(guān)C# Task.Run使用內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

最新評論