快捷導(dǎo)航

C#中ThreadStart委托的實現(xiàn)

更新時間：2025年05月20日 09:35:32 作者：CoderIsArt

ThreadStart是.NET中的一個內(nèi)置委托類型,表示無參數(shù)且無返回值的方法,本文主要介紹了C#中ThreadStart委托的實現(xiàn),具有一定的參考價值,感興趣的可以了解一下

1.ThreadStart 委托：

ThreadStart 是 .NET 中的一個內(nèi)置委托類型，表示無參數(shù)且無返回值的方法。其定義如下：

public delegate void ThreadStart();

通常用于定義線程的入口方法。
List<ThreadStart>：
這是一個泛型集合，用于存儲多個 ThreadStart 委托實例。每個委托代表一個待執(zhí)行的任務(wù)。
整體作用：
創(chuàng)建一個線程任務(wù)隊列，用于保存需要通過線程執(zhí)行的多個方法。

2. 典型使用場景

private List<ThreadStart> delegates = new List<ThreadStart>();

(1) 多任務(wù)隊列管理

// 添加任務(wù)到隊列
delegates.Add(() => Console.WriteLine("Task 1"));
delegates.Add(() => File.WriteAllText("test.txt", "Hello"));

// 啟動線程執(zhí)行所有任務(wù)
foreach (var task in delegates)
{
    new Thread(task).Start();
}

(2) 延遲執(zhí)行控制

// 先收集任務(wù)
delegates.Add(() => DownloadFile(url1));
delegates.Add(() => ProcessData(data));

// 在適當(dāng)時候觸發(fā)執(zhí)行
void ExecuteAllTasks()
{
    foreach (var task in delegates)
    {
        new Thread(task).Start();
    }
}

3. 技術(shù)細(xì)節(jié)

委托與線程的關(guān)系

每個 ThreadStart 委托可以傳遞給 Thread 構(gòu)造函數(shù)，作為線程啟動時執(zhí)行的方法。
示例：

ThreadStart task = () => Console.WriteLine("Running in thread");
Thread thread = new Thread(task);
thread.Start();

線程安全注意事項

非線程安全集合：
List<T> 本身不是線程安全的。若多線程同時修改集合（如添加/刪除任務(wù)），需加鎖：

private readonly object _lock = new object();

void AddTask(ThreadStart task)
{
    lock (_lock)
    {
        delegates.Add(task);
    }
}

4. 完整使用示例

using System;
using System.Collections.Generic;
using System.Threading;

class TaskScheduler
{
    private List<ThreadStart> _tasks = new List<ThreadStart>();
    private readonly object _lock = new object();

    public void AddTask(Action action)
    {
        lock (_lock)
        {
            _tasks.Add(new ThreadStart(action));
        }
    }

    public void ExecuteAll()
    {
        List<Thread> threads = new List<Thread>();
        
        lock (_lock)
        {
            foreach (var task in _tasks)
            {
                Thread thread = new Thread(task);
                threads.Add(thread);
                thread.Start();
            }
            _tasks.Clear();
        }

        // 等待所有線程完成（可選）
        foreach (var thread in threads)
        {
            thread.Join();
        }
    }
}

// 使用示例
var scheduler = new TaskScheduler();
scheduler.AddTask(() => Console.WriteLine("Task 1"));
scheduler.AddTask(() => Thread.Sleep(1000));
scheduler.ExecuteAll();

5. 替代方案（現(xiàn)代C#推薦）

使用 Task 和 ConcurrentQueue

using System.Collections.Concurrent;
using System.Threading.Tasks;

private ConcurrentQueue<Action> _taskQueue = new ConcurrentQueue<Action>();

// 添加任務(wù)
_taskQueue.Enqueue(() => Console.WriteLine("Task 1"));

// 并行執(zhí)行
Parallel.ForEach(_taskQueue, task => task.Invoke());
_taskQueue.Clear();

優(yōu)點

更高效的線程池管理（通過 Task）
天生線程安全的集合（ConcurrentQueue）
支持 async/await

6. 關(guān)鍵區(qū)別：ThreadStart vs Action

特性	ThreadStart	Action
返回值	無 (`void`)	無 (`void`)
參數(shù)	無	可帶參數(shù)（如 `Action<int>`）
用途	專用于 `Thread` 構(gòu)造函數(shù)	通用委托
現(xiàn)代性	較舊 API	推薦使用