C#多线程详解

简介: C#多线程详解

多线程是指在一个应用程序中同时执行多个线程,这些线程可以并行执行,从而提高程序的执行效率。在C#语言中,多线程是通过System.Threading命名空间中的类实现的。本文将举例详细介绍C#中的多线程编程。

1.创建线程

C#中创建线程的方式有多种,其中最常用的方式是通过Thread类,示例代码如下:

using System;
using System.Threading;
 
class Program
{
    static void Main(string[] args)
    {
        Thread thread = new Thread(new ThreadStart(TestMethod));
        thread.Start();
    }
 
    static void TestMethod()
    {
        Console.WriteLine("This is a test method.");
    }
}

在上述例子中,我们首先引用了System.Threading命名空间,然后创建了一个Thread对象,并将其初始化为一个ThreadStart类型的委托。最后调用Start方法来启动线程。当调用Start方法后,TestMetod方法就会在新启动的线程中运行。

2.线程同步

在多线程编程中,线程同步是非常重要的一个概念。由于多个线程可能同时访问同一个共享资源,为了保证其正确性和可靠性,必须采取一系列的同步方法。下面是几种常见的线程同步方法:

2.1. lock语句

lock语句是一种最常用的线程同步方法,它可以确保在同一时间只有一个线程可以进入代码块中执行。示例代码如下:

using System;
using System.Threading;
 
class Program
{
    static int count = 0;
    static object locker = new object();
 
    static void Main(string[] args)
    {
        Thread thread1 = new Thread(new ThreadStart(TestMethod));
        Thread thread2 = new Thread(new ThreadStart(TestMethod));
        thread1.Start();
        thread2.Start();
 
        Console.ReadLine();
    }
 
    static void TestMethod()
    {
        lock (locker)
        {
            for (int i = 0; i < 100; i++)
            {
                count++;
                Console.WriteLine($"Thread ID:{Thread.CurrentThread.ManagedThreadId}, Count:{count}");
            }
        }
    }
}

在上述示例中,我们使用了一个全局变量count和一个名为locker的对象来同步线程的执行。在TestMethod方法中,我们使用了lock语句,它会锁定locker对象,使得只有当前线程可以进入执行。因此,当多个线程同时访问count变量时,就不会发生数据竞争的情况。

2.2. SemaphoreSlim类

SemaphoreSlim类是一种基于信号量的同步方法,它可以控制同时访问某一资源的线程数量。示例代码如下:

using System;
using System.Threading;
 
class Program
{
    static int count = 0;
    static SemaphoreSlim semaphore = new SemaphoreSlim(2, 2);
 
    static void Main(string[] args)
    {
        Thread thread1 = new Thread(new ThreadStart(TestMethod));
        Thread thread2 = new Thread(new ThreadStart(TestMethod));
        Thread thread3 = new Thread(new ThreadStart(TestMethod));
        Thread thread4 = new Thread(new ThreadStart(TestMethod));
        thread1.Start();
        thread2.Start();
        thread3.Start();
        thread4.Start();
 
        Console.ReadLine();
    }
 
    static void TestMethod()
    {
        semaphore.Wait();
        for (int i = 0; i < 100; i++)
        {
            count++;
            Console.WriteLine($"Thread ID:{Thread.CurrentThread.ManagedThreadId}, Count:{count}");
        }
        semaphore.Release();
    }
}

在上述示例中,我们创建了一个SemaphoreSlim对象,用于限制最多只能有两个线程同时访问临界区域。在TestMethod方法中,我们首先调用了Wait方法来等待信号量可用,然后进行数据的操作,最后调用Release方法来释放信号量。

3.线程安全集合

在多线程编程中,访问共享资源时往往需要进行线程同步。C#中提供了一系列的线程安全集合来便于我们进行线程同步。常用的线程安全集合有如下几种:

3.1. ConcurrentDictionary

ConcurrentDictionary是一种线程安全的字典集合,可以在多个线程同时操作时保证数据的安全性。示例代码如下:

using System;
using System.Collections.Concurrent;
 
class Program
{
    static ConcurrentDictionary<string, int> keyValuePairs = new ConcurrentDictionary<string, int>();
 
    static void Main(string[] args)
    {
        Thread thread1 = new Thread(new ThreadStart(TestMethod));
        Thread thread2 = new Thread(new ThreadStart(TestMethod));
        thread1.Start();
        thread2.Start();
 
        Console.ReadLine();
    }
 
    static void TestMethod()
    {
        for (int i = 0; i < 100; i++)
        {
            keyValuePairs.TryAdd($"key{i}", i);
            Console.WriteLine($"Thread ID:{Thread.CurrentThread.ManagedThreadId}, Add key{i}");
        }
    }
}

在上述示例中,我们创建了一个ConcurrentDictionary对象,它提供了TryAdd方法来安全地添加元素。因此,当多个线程同时执行添加操作时,不会发生数据竞争的情况。

3.2. ConcurrentQueue

ConcurrentQueue是一种线程安全的队列集合,可以保证在多个线程同时使用时安全性。示例代码如下:

using System;
using System.Collections.Concurrent;
 
class Program
{
    static ConcurrentQueue<string> queue = new ConcurrentQueue<string>();
 
    static void Main(string[] args)
    {
        Thread thread1 = new Thread(new ThreadStart(TestMethod));
        Thread thread2 = new Thread(new ThreadStart(TestMethod));
        thread1.Start();
        thread2.Start();
 
        Console.ReadLine();
    }
 
    static void TestMethod()
    {
        for (int i = 0; i < 100; i++)
        {
            queue.Enqueue($"Item{i}");
            Console.WriteLine($"Thread ID:{Thread.CurrentThread.ManagedThreadId}, Enqueue:Item{i}");
        }
    }
}

在上述示例中,我们创建了一个ConcurrentQueue对象,并使用Enqueue方法来安全地添加元素。因此,当多个线程同时执行添加操作时,就不会发生数据竞争的情况。

4.线程池

C#中的线程池用来精细管理线程的创建和销毁,避免了频繁创建和销毁线程的开销。通过线程池,我们可以更加高效地利用系统资源。示例代码如下:

using System;
using System.Threading;
 
class Program
{
    static int count = 0;
 
    static void Main(string[] args)
    {
        for (int i = 0; i < 10; i++)
        {
            ThreadPool.QueueUserWorkItem(new WaitCallback(TestMethod), i);
        }
 
        Console.ReadLine();
    }
 
    static void TestMethod(object state)
    {
        Interlocked.Increment(ref count);
        Console.WriteLine($"Thread ID:{Thread.CurrentThread.ManagedThreadId}, Count:{count}, State:{state}");
    }
}

在上述示例中,我们使用线程池来运行TestMethod方法。通过ThreadPool.QueueUserWorkItem方法,我们可以将TestMethod方法添加到线程池中进行执行。由于线程池内部维护了一定数量的线程,因此当我们使用线程池运行多个方法时,可以避免频繁地创建和销毁线程。

总之,以上就是C#多线程编程的介绍和举例。在实际开发中,多线程编程是非常常见的技术手段,因此我们需要掌握多线程的相关知识和技巧,以提高程序的效率和稳定性。


相关文章
|
6月前
|
SQL 开发框架 安全
C#编程与多线程处理
【4月更文挑战第21天】探索C#多线程处理,提升程序性能与响应性。了解C#中的Thread、Task类及Async/Await关键字,掌握线程同步与安全,实践并发计算、网络服务及UI优化。跟随未来发展趋势,利用C#打造高效应用。
199 3
|
6月前
|
安全 编译器 C#
C#学习相关系列之多线程---lock线程锁的用法
C#学习相关系列之多线程---lock线程锁的用法
|
6月前
|
Java 调度 C#
C#学习系列相关之多线程(一)----常用多线程方法总结
C#学习系列相关之多线程(一)----常用多线程方法总结
|
3月前
|
数据采集 XML JavaScript
C# 中 ScrapySharp 的多线程下载策略
C# 中 ScrapySharp 的多线程下载策略
|
2月前
|
安全 数据库连接 API
C#一分钟浅谈:多线程编程入门
在现代软件开发中,多线程编程对于提升程序响应性和执行效率至关重要。本文从基础概念入手,详细探讨了C#中的多线程技术,包括线程创建、管理及常见问题的解决策略,如线程安全、死锁和资源泄露等,并通过具体示例帮助读者理解和应用这些技巧,适合初学者快速掌握C#多线程编程。
79 0
|
3月前
|
安全 C# 开发者
【C# 多线程编程陷阱揭秘】:小心!那些让你的程序瞬间崩溃的多线程数据同步异常问题,看完这篇你就能轻松应对!
【8月更文挑战第18天】多线程编程对现代软件开发至关重要,特别是在追求高性能和响应性方面。然而,它也带来了数据同步异常等挑战。本文通过一个简单的计数器示例展示了当多个线程无序地访问共享资源时可能出现的问题,并介绍了如何使用 `lock` 语句来确保线程安全。此外,还提到了其他同步工具如 `Monitor` 和 `Semaphore`,帮助开发者实现更高效的数据同步策略,以达到既保证数据一致性又维持良好性能的目标。
48 0
|
5月前
|
并行计算 算法 C#
C# Mandelbrot和Julia分形图像生成程序更新到2010-9-14版 支持多线程计算 多核处理器
此文档是一个关于分形图像生成器的介绍,作者分享了个人开发的M-J算法集成及色彩创新,包括源代码和历史版本。作者欢迎有兴趣的读者留言交流,并提供了邮箱(delacroix_xu@sina.com)以分享资源。文中还展示了程序的发展历程,如增加了真彩色效果、圈选放大、历史记录等功能,并分享了几幅精美的分形图像。此外,还提到了程序的新特性,如导入ini文件批量输出图像和更新一批图片的功能。文档末尾附有多张程序生成的高分辨率分形图像示例。
|
5月前
|
大数据 C#
C#实现多线程的几种方式
C#实现多线程的几种方式
|
6月前
|
C#
C#学习系列相关之多线程(二)----Thread类介绍
C#学习系列相关之多线程(二)----Thread类介绍