聊聊 C# 中的多线程编程-编程学习网

一、线程的创建

在C#中，创建线程主要有两种方式：使用Thread类和使用Task类。

1. 使用Thread类创建线程

Thread类是.NET Framework中用于创建和管理线程的基本类。下面是一个简单的示例，演示如何使用Thread类创建一个新线程：

using System;
using System.Threading;

class Program
{
    static void Main(string[] args)
    {
        Thread newThread = new Thread(DoWork);
        newThread.Start();
        
        // 主线程继续执行其他任务
        Console.WriteLine("Main thread is running...");
        newThread.Join(); // 等待新线程完成
        Console.WriteLine("New thread has finished.");
    }

    static void DoWork()
    {
        Console.WriteLine("New thread is running...");
        Thread.Sleep(2000); // 模拟耗时操作
    }
}

在这个示例中，我们创建了一个名为newThread的Thread对象，并将其启动。DoWork方法将在新线程上执行。

2. 使用Task类创建线程

从C# 4.0开始，引入了Task类，它提供了更高级的异步编程模型。下面是使用Task类创建线程的示例：

using System;
using System.Threading.Tasks;

class Program
{
    static void Main(string[] args)
    {
        Task task = Task.Run(() => DoWork());
        
        // 主线程继续执行其他任务
        Console.WriteLine("Main thread is running...");
        task.Wait(); // 等待任务完成
        Console.WriteLine("Task has finished.");
    }

    static void DoWork()
    {
        Console.WriteLine("Task is running...");
        Thread.Sleep(2000); // 模拟耗时操作
    }
}

在这个示例中，我们使用Task.Run方法创建了一个任务，并在其中执行了DoWork方法。这种方式更加简洁，并且与异步编程模型更好地集成。

二、线程的同步

当多个线程需要访问共享资源时，就需要进行线程同步以防止数据竞争和死锁等问题。C#提供了多种同步机制，如lock语句、Monitor类、Mutex、Semaphore和EventWaitHandle等。

下面是一个使用lock语句进行线程同步的示例：

using System;
using System.Threading;

class Account
{
    private Object thisLock = new Object();
    int balance;

    public Account(int initial)
    {
        balance = initial;
    }

    public void Withdraw(int amount)
    {
        // 使用lock语句确保同一时间只有一个线程可以访问balance变量
        lock (thisLock)
        {
            if (balance >= amount)
            {
                Console.WriteLine("Balance before Withdrawal :  " + balance);
                balance = balance - amount;
                Console.WriteLine("Balance after Withdrawal : " + balance);
            }
            else
            {
                Console.WriteLine("Insufficient balance");
            }
        }
    }
}

class Program
{
    static void Main()
    {
        Account acc = new Account(100);
        Thread t1 = new Thread(() => acc.Withdraw(50));
        Thread t2 = new Thread(() => acc.Withdraw(60));
        t1.Start();
        t2.Start();
        t1.Join();
        t2.Join();
    }
}

在这个示例中，我们使用lock语句来确保同一时间只有一个线程可以修改balance变量，从而避免了数据竞争。

三、线程间的通信

线程间通信通常通过使用共享变量、信号量、事件等方式实现。在C#中，可以使用AutoResetEvent、ManualResetEvent、Semaphore、Mutex等类来实现线程间的同步和通信。

下面是一个使用AutoResetEvent进行线程间通信的示例：

using System;
using System.Threading;

class Program
{
    static AutoResetEvent autoEvent = new AutoResetEvent(false);
    static bool isSignaled = false;

    static void Main()
    {
        Thread t = new Thread(DoWork);
        t.Start();
        
        // 模拟主线程做一些其他工作，然后等待信号
        Thread.Sleep(1000);
        Console.WriteLine("Waiting for signal...");
        autoEvent.WaitOne(); // 等待信号
        Console.WriteLine("Signaled!");
    }

    static void DoWork()
    {
        Console.WriteLine("Worker thread is running...");
        Thread.Sleep(2000); // 模拟耗时操作
        isSignaled = true;
        autoEvent.Set(); // 发送信号给等待的线程
    }
}

在这个示例中，工作线程在完成某项工作后，通过AutoResetEvent发送信号给主线程，通知它工作已经完成。

四、线程安全问题

线程安全是多线程编程中的重要概念。当多个线程同时访问和修改共享数据时，可能会导致数据不一致的问题。为了确保线程安全，可以采取以下措施：

使用同步机制：如前面提到的lock语句、Monitor类等，确保同一时间只有一个线程可以访问共享资源。
使用线程安全的数据结构：如ConcurrentDictionary、ConcurrentQueue等，这些数据结构内部已经实现了必要的同步机制。
避免共享可变状态：尽量减少线程间共享的可变状态，可以使用局部变量或线程局部存储（Thread-Local Storage, TLS）来存储线程特有的数据。
使用不可变对象：不可变对象在创建后其状态就不能再改变，因此是线程安全的。

五、总结

多线程编程是提高程序性能和响应速度的重要手段，但也带来了线程同步、通信和线程安全等挑战。C#提供了丰富的多线程支持和同步机制，使得开发者能够更容易地编写高效且安全的多线程程序。通过本文的探讨和示例代码，希望读者能够更深入地理解C#中的多线程编程，并在实际开发中加以应用。

文章详情

聊聊 C# 中的多线程编程