异常教程

C# 多线程（千字长文）

更新时间:

💡一则或许对你有用的小广告

欢迎加入小哈的星球 ，你将获得：专属的项目实战(已更新的所有项目都能学习) / 1v1 提问 / Java 学习路线 / 学习打卡 / 每月赠书 / 社群讨论

  • 新开坑项目:《Spring AI 项目实战》 正在持续爆肝中，基于 Spring AI + Spring Boot 3.x + JDK 21...， 点击查看 ;
  • 《从零手撸：仿小红书（微服务架构）》 已完结，基于 Spring Cloud Alibaba + Spring Boot 3.x + JDK 17...，点击查看项目介绍 ;演示链接： http://116.62.199.48:7070 ;
  • 《从零手撸：前后端分离博客项目（全栈开发）》 2 期已完结，演示链接： http://116.62.199.48/ ;

截止目前， 星球 内专栏累计输出 90w+ 字，讲解图 3441+ 张，还在持续爆肝中.. 后续还会上新更多项目，目标是将 Java 领域典型的项目都整一波，如秒杀系统, 在线商城, IM 即时通讯，权限管理，Spring Cloud Alibaba 微服务等等，已有 3100+ 小伙伴加入学习 ，欢迎点击围观

前言

在现代应用程序开发中，多线程技术是提升程序性能和响应能力的核心手段。无论是处理复杂计算、实现异步操作，还是优化用户界面的流畅度，C# 多线程都扮演着关键角色。然而，对于编程初学者和中级开发者而言，多线程的概念往往显得抽象且复杂。本文将通过循序渐进的方式，结合实例和比喻，帮助读者理解多线程的核心原理，并掌握实际开发中的应用技巧。

一、线程与进程：基础概念解析

1.1 线程的定义与作用

线程是程序执行的最小单位，可以理解为“程序运行的路径”。一个进程可以包含多个线程，每个线程负责独立的任务。例如，一个音乐播放器的进程可能包含主线程（负责界面交互）和子线程（负责后台下载或音频解码）。

比喻：
想象一个工厂的生产线，每个工人（线程）负责不同的任务（如组装、质检、包装）。主线程如同工厂的管理者，负责协调所有工人的工作，而子线程则专注于各自的职责，从而提高整体效率。

1.2 多线程的优势

  • 提升性能：并行执行多个任务，缩短总耗时。
  • 增强响应性：避免因长时间任务阻塞主线程，导致界面卡顿。
  • 资源利用率：充分利用多核 CPU 的计算能力。

二、创建线程的三种方式

C# 提供了多种创建和管理线程的 API，开发者可根据需求灵活选择。

2.1 使用 Thread 类直接创建线程

通过 System.Threading.Thread 类，可以显式地创建和启动线程。

代码示例：

using System.Threading;

class Program
{
    static void Main()
    {
        // 定义线程执行的委托
        Thread thread = new Thread(new ThreadStart(PrintNumbers));
        thread.Start();  // 启动线程
        
        Console.WriteLine("主线程正在执行其他任务...");
    }

    static void PrintNumbers()
    {
        for (int i = 0; i < 5; i++)
        {
            Console.WriteLine($"子线程：{i}");
            Thread.Sleep(200);  // 模拟耗时操作
        }
    }
}

输出示例：

主线程正在执行其他任务...
子线程：0
子线程：1
子线程：2
子线程：3
子线程：4

2.2 使用 Task 和 async/await 实现异步编程

Task 是 C# 4.0 引入的更高级的异步模型，结合 async 和 await 关键字，可以更简洁地管理线程。

代码示例：

using System.Threading.Tasks;

class Program
{
    static async Task Main()
    {
        Console.WriteLine("主线程开始");
        await Task.Run(() => PrintNumbers());  // 异步执行任务
        Console.WriteLine("主线程结束");
    }

    static void PrintNumbers()
    {
        for (int i = 0; i < 5; i++)
        {
            Console.WriteLine($"子线程：{i}");
            Thread.Sleep(200);
        }
    }
}

特点：

  • Task.Run 自动将任务分配到线程池中的线程执行。
  • async/await 使异步代码更易读，避免回调地狱。

2.3 线程池（Thread Pool）的高效利用

线程池通过复用已存在的线程，减少线程创建和销毁的开销。使用 ThreadPool.QueueUserWorkItem 方法提交任务。

代码示例：

using System.Threading;

class Program
{
    static void Main()
    {
        // 提交任务到线程池
        ThreadPool.QueueUserWorkItem(PrintNumbers);
        
        Console.WriteLine("主线程继续执行...");
        Console.ReadLine();  // 阻塞主线程，确保子线程完成
    }

    static void PrintNumbers(object state)
    {
        for (int i = 0; i < 5; i++)
        {
            Console.WriteLine($"线程池线程：{i}");
            Thread.Sleep(200);
        }
    }
}

优势：

  • 线程池由 CLR 管理，自动调整线程数量。
  • 适合短时间、高频率的任务。

三、多线程中的同步问题与解决方案

3.1 竞态条件（Race Condition）

当多个线程同时访问共享资源且未加保护时，可能导致数据不一致。例如，两个线程同时递增一个计数器，可能因操作顺序问题导致结果错误。

示例场景：

int counter = 0;

// 线程 A 和线程 B 同时执行以下代码：
counter += 1;  // 可能导致丢失更新

3.2 同步机制：锁（Lock）

使用 lock 关键字为共享资源加锁，确保同一时间只有一个线程访问。

修复代码：

object lockObject = new object();
int counter = 0;

// 线程 A 和线程 B 执行：
lock (lockObject)
{
    counter += 1;
}

3.3 更高级的同步工具

C# 提供了多种同步类，如 Monitor、Mutex、Semaphore，以及线程安全的集合类（如 ConcurrentQueue）。

代码示例：使用 ConcurrentQueue：

using System.Collections.Concurrent;

ConcurrentQueue<int> queue = new ConcurrentQueue<int>();

// 线程 A 入队操作：
queue.Enqueue(1);

// 线程 B 出队操作：
queue.TryDequeue(out int result);

四、多线程的高级主题与最佳实践

4.1 线程优先级与调度

通过 Thread.Priority 属性调整线程的优先级，影响 CPU 时间片分配。

代码示例：

Thread highPriorityThread = new Thread(HeavyTask);
highPriorityThread.Priority = ThreadPriority.Highest;
highPriorityThread.Start();

4.2 线程间通信与协作

  • 事件（Event）：通过 ManualResetEvent 或 AutoResetEvent 实现线程间的信号传递。
  • 线程间数据共享：推荐使用线程安全的集合或 Interlocked 类操作原子变量。

4.3 避免常见陷阱

  • 死锁：多个线程互相等待对方释放锁，导致程序停滞。
  • 资源泄漏：未正确释放线程或未处理异常，导致线程无法回收。
  • 过度线程化：线程数量过多可能因上下文切换消耗性能。

五、实践案例：实现一个简单的多线程下载器

5.1 需求分析

编写一个支持多线程下载的工具，通过并行下载多个文件块，提升下载速度。

5.2 实现步骤

  1. 划分文件块：将文件分成多个片段，每个线程下载一个片段。
  2. 线程管理：使用线程池或 Task 并行执行下载任务。
  3. 合并结果：将下载的片段合并为完整文件。

5.3 代码示例

using System;
using System.IO;
using System.Net;
using System.Threading.Tasks;

class ParallelDownloader
{
    public static async Task DownloadAsync(string url, string fileName)
    {
        using (WebClient client = new WebClient())
        {
            byte[] data = await client.DownloadDataTaskAsync(url);
            
            // 将数据分割为 4 个线程处理
            int chunkSize = data.Length / 4;
            await Task.WhenAll(
                WriteChunk(data, 0, chunkSize, fileName),
                WriteChunk(data, chunkSize, chunkSize * 2, fileName),
                WriteChunk(data, chunkSize * 2, chunkSize * 3, fileName),
                WriteChunk(data, chunkSize * 3, data.Length, fileName)
            );
        }
    }

    private static async Task WriteChunk(byte[] data, int start, int end, string fileName)
    {
        using (FileStream fs = new FileStream(fileName, FileMode.Append))
        {
            await fs.WriteAsync(data, start, end - start);
        }
    }
}

结论

掌握 C# 多线程 是成为高效开发者的重要里程碑。通过本文的讲解，读者应能理解线程的基本概念、创建方法、同步策略及实际应用场景。在开发中，合理利用多线程可以显著提升程序性能，但需注意避免同步问题和资源管理不当的风险。建议读者通过实践项目（如并发服务器、数据处理工具）进一步巩固知识，逐步掌握多线程编程的精髓。

通过持续学习和优化，多线程技术将成为你开发高性能、响应迅速应用程序的核心工具。

最新发布

查看更多文章