C#多线程开发基础：从Thread到Task的演进与实现

为何引入多线程

在C#应用开发中，使用多线程主要基于以下三个考量：

• 隔离性与可靠性：将独立的功能模块放入不同线程，避免相互干扰，提高程序整体稳定性。
• 简化编码逻辑：对于耗时操作（如网络请求、文件读写），将其置于后台线程可避免阻塞主界面或主流程，使代码逻辑更清晰。
• 并发执行能力：利用多核CPU优势，同时处理多个任务以提升系统吞吐量。

基本概念与生命周期控制

理解线程的运行状态与管理方式是编写安全并发代码的前提：

1. 进程与线程关系：进程是资源分配的基本单位，包含一个或多个线程。线程共享进程资源但拥有独立的栈空间，不直接占用进程级内存资源。
2. 前台与后台线程：默认创建的 Thread 为前台线程。当所有前台线程结束时，无论后台线程是否运行完毕，进程都会强制终止。
3. 阻塞与同步：Join 方法用于阻塞当前线程，直到目标线程执行结束。这是确保执行顺序的重要机制。
4. 线程中断与异常：Abort 会抛出 ThreadAbortException 强制终止线程且不可逆；Interrupt 则抛出 ThreadInterruptedException，允许通过捕获异常进行优雅退出。
5. 优先级设置：可通过 Priority 属性设置为 Highest、AboveNormal、Normal（默认）、BelowNormal 或 Lowest。

需要注意的是，传统API中的挂起（Suspend）和恢复（Resume）极易导致死锁，在实际开发中应尽量避免使用。

第一种方式：直接使用 Thread

最基础的线程创建方式使用 System.Threading.Thread 类。该方法灵活度高，适合需要精细控制线程生命周期的场景。

第一步：构建无参数线程

使用 ThreadStart 委托定义无参线程体，并通过 Start() 启动。

class Program
{
    static void Main(string[] args)
    {
        // 1. 创建无参数线程
        Thread t1 = new Thread(new ThreadStart(TestMethod));
        
        // 2. 设置为后台线程（随主线程退出而退出）
        t1.IsBackground = true;
        
        // 3. 启动线程
        t1.Start();
        
        Console.ReadKey();
    }

    public static void TestMethod()
    {
        Console.WriteLine("不带参数的线程函数");
    }
}

第二步：构建带参数线程

当线程需要接收外部数据时，使用 ParameterizedThreadStart。注意参数类型固定为 object，内部需进行类型转换。

// 创建带参线程
Thread t2 = new Thread(new ParameterizedThreadStart(TestMethodParam));
t2.IsBackground = true;
t2.Start("hello"); // 传入string参数

// 线程入口函数
public static void TestMethodParam(object data)
{
    string datastr = data as string;
    Console.WriteLine("带参数的线程函数，参数为：{0}", datastr);
}

第二种方式：使用 ThreadPool

频繁创建和销毁 Thread 会带来较大的内存与CPU开销。线程池（ThreadPool）通过维护一组长期存在的线程并复用它们来处理队列中的任务，有效降低了资源消耗。池中的线程默认为后台线程。

第一步：提交异步任务

使用 QueueUserWorkItem 将工作项推入线程池队列，无需显式创建和启动线程。

static void Main(string[] args)
{
    // 提交带有object类型参数的任务
    ThreadPool.QueueUserWorkItem(TestMethodPool, "Hello from Pool");
    
    // 主线程休眠防止程序过早退出
    Thread.Sleep(1000); 
    Console.ReadKey();
}

public static void TestMethodPool(object state)
{
    string msg = state as string;
    Console.WriteLine(msg);
}

第三种方式：使用 Task (推荐)

System.Threading.Tasks.Task 代表了异步操作，提供了比线程池更高级的抽象。它不仅支持异步执行，还内置了任务完成通知、返回值获取和错误处理机制。

第一步：创建并获取返回值

构造 Task<TResult> 对象并调用 Wait() 等待执行完毕，随后通过 Result 属性获取结果。

static void Main(string[] args)
{
    // 创建计算1加到1000的任务
    Task<Int32> t = new Task<Int32>(n => Sum((Int32)n), 1000);
    
    t.Start();
    t.Wait(); // 阻塞直到完成
    
    Console.WriteLine(t.Result); // 输出结果 500500
}

private static Int32 Sum(Int32 n)
{
    Int32 sum = 0;
    for (; n > 0; --n)
        checked { sum += n; } // 溢出检查
    return sum;
}

第二步：使用 ContinueWith 非阻塞回调

如果需要在线程完成后自动触发后续操作，可使用 ContinueWith，这种方式不会阻塞当前线程。

static void Main(string[] args)
{
    Task<Int32> t = new Task<Int32>(n => Sum((Int32)n), 1000);
    t.Start();
    
    // 任务结束后打印结果，不阻塞主线程
    t.ContinueWith(task => Console.WriteLine("The result is {0}", task.Result));
    
    Console.ReadKey();
}

第四种方式：委托异步模式 (BeginInvoke/EndInvoke)

C#提供的早期异步设计模式，通过 IAsyncResult 接口实现异步调用和回调，适用于遗留代码或特定框架集成场景。

namespace Test
{
    public delegate string MyDelegate(object data);
    class Program
    {
        static void Main(string[] args)
        {
            MyDelegate mydelegate = new MyDelegate(TestMethod);
            
            // 发起异步调用，指定回调函数
            IAsyncResult result = mydelegate.BeginInvoke(
                "Thread Param", 
                TestCallback,     
                "Callback Param"
            );

            // 最终阻塞以获取返回值（实际应用中通常不这样做）
            string resStr = mydelegate.EndInvoke(result);
        }

        public static string TestMethod(object data)
        {
            Console.WriteLine(data);
            return "Returned";
        }

        // 异步回调方法
        public static void TestCallback(IAsyncResult ar)
        {
            Console.WriteLine(ar.AsyncState); // 输出 Callback Param
        }
    }
}

在上述模式中，当委托绑定的方法执行即将返回时，会自动触发 TestCallback 回调函数。

总结

从基础的 Thread 到现代化的 Task，C#提供了丰富的多线程工具。对于简单的后台任务推荐使用 Task 配合 async/await；对于大量短时任务，线程池能有效复用资源；仅在需要对单个线程生命周期进行精细控制时才考虑直接使用 Thread API。

以上就是C#多线程开发的详细内容，更多关于C#并发编程、Task用法和异步调用的资料请关注本站其它相关文章！