线程详解——c#

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了线程详解——c#，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含9348字，纯文字阅读大概需要14分钟。

内容图文

本文目录：

线程的简单使用

并发和异步的区别

并发控制 - 锁

线程的信号机制

线程池中的线程

案例：支持并发的异步日志组件

线程的简单使用

常见的并发和异步大多是基于线程来实现的，所以本文先讲线程的简单使用方法。

使用线程，我们需要引用System.Threading命名空间。创建一个线程最简单的方法就是在 new 一个 Thread，并传递一个ThreadStart委托（无参数）或ParameterizedThreadStart委托（带参数），如下：

class Program {
    static void Main(string[] args) {

        // 使用无参数委托ThreadStart
        Thread t = new Thread(Go);
        t.Start();

        // 使用带参数委托ParameterizedThreadStart
        Thread t2 = new Thread(GoWithParam);
        t2.Start("Message from main.");

        t2.Join();// 等待线程t2完成。

        Console.WriteLine("Thread t2 has ended!");
        Console.ReadKey();
    }

    static void Go() {
        Console.WriteLine("Go!");
    }

    static void GoWithParam(object msg) {
        Console.WriteLine("Go With Param! Message: " + msg);
        Thread.Sleep(1000);// 模拟耗时操作
    }
}

运行结果：

线程详解——c# - 文章图片

线程的用法，我们只需要了解这么多。下面我们再来通过一段代码来讲讲并发和异步。

并发和异步的区别

关于并发和异步，我们先来写一段代码，模拟多个线程同时写1000条日志：

class Program {
    static void Main(string[] args) {

        Thread t1 = new Thread(Working);
        t1.Name = "Thread1";
        Thread t2 = new Thread(Working);
        t2.Name = "Thread2";
        Thread t3 = new Thread(Working);
        t3.Name = "Thread3";

        // 依次启动3个线程。
        t1.Start();
        t2.Start();
        t3.Start();

        Console.ReadKey();
    }

    // 每个线程都同时在工作
    static void Working() {
        // 模拟1000次写日志操作
        for (int i = 0; i < 1000; i++) {
            //  异步写文件
            Logger.Write(Thread.CurrentThread.Name + " writes a log: " + i + ", on " + DateTime.Now.ToString() + ".\n");
        }// 做一些其它的事件
        for (int i = 0; i < 1000; i++) { }
    }
}

代码很简单，相信大家都能看得懂。Logger 大家可以把它看做是一个写日志的组件，先不关心它的具体实现，只要知道它是一个提供了写日志功能的组件就行。

那么，这段代码跟并发和异步有什么关系呢？

我们先用一张图来描述这段代码：

线程详解——c# - 文章图片

观察上图，3个线程同时调用Logger写日志，对于Logger来说，3个线程同时交给了它任务，这种情况就是并发。对于其中一个线程来说，它在工作过程中，在某个时间请求Logger帮它写日志，同时又继续在自己的其它工作，这种情况就是异步。

（经读者反馈，为不“误导”读者（尽管我个人不觉得是误导。之前我的定义和解释不全面，没有从操作系统和CPU层次去区分这两个概念。我的文章不喜欢搬教科书，只是想用通俗易读的白话让大家理解），为了知识的专业性和严谨，现已把我理解的对并发和异步的定义删除，感谢园友们的热心讨论）。

接下来，我们继续讲几个很有用的有关线程和并发的知识 - 锁、信号机制和线程池。

并发控制 - 锁

CLR 会为每个线程分配自己的内存堆空间，以使他们的本地变量保持分离互不干扰。

线程之间也可以共享通用的数据，比如同一对象的某个属性或全局静态变量。但线程间共享数据是存在安全问题的。举个例子，下面的主线程和新线程共享了变量done，done用来标识某件事已经做过了（告诉其它线程不要再重复做了）：

class Program {
    static bool done;
    static void Main(string[] args) {

        new Thread(Go).Start(); // 在新的线程上调用Go
        Go(); // 在主线程上调用Go

        Console.ReadKey();
    }

    static void Go() {
        if (!done) {
            Thread.Sleep(500); // 模拟耗时操作
            Console.WriteLine("Done"); 
            done = true;
        }
    }
}

输出结果：

线程详解——c# - 文章图片

输出了两个“Done”，事件被做了两次。由于没有控制好并发，这就出现了线程的安全问题，无法保证数据的状态。

要解决这个问题，就需要用到锁（Lock，也叫排它锁或互斥锁）。使用lock语句，可以保证共享数据只能同时被一个线程访问。lock的数据对象要求是不能null的引用类型的对象，所以lock的对象需保证不能为空。为此需要创建一个不为空的对象来使用锁，修改一下上面的代码如下：

class Program {

    static bool done;
    static object locker = new object(); // ！！

    static void Main(string[] args) {

        new Thread(Go).Start(); // 在新的线程上调用Go
        Go(); // 在主线程上调用Go

        Console.ReadKey();
    }

    static void Go() {
        lock (locker) {
            if (!done) {
                Thread.Sleep(500); // Doing something.
                Console.WriteLine("Done");
                done = true;
            }
        }
    }
}

再看结果：

线程详解——c# - 文章图片

使用锁，我们解决了问题。但使用锁也会有另外一个线程安全问题，那就是“死锁”，死锁的概率很小，但也要避免。保证“上锁”这个操作在一个线程上执行是避免死锁的方法之一，这种方法在下文案例中会用到。

这里我们就不去深入研究“死锁”了，感兴趣的朋友可以去查询相关资料。

线程的信号机制

有时候你需要一个线程在接收到某个信号时，才开始执行，否则处于等待状态，这是一种基于信号的事件机制。.NET框架提供一个 ManualResetEvent类来处理这类事件，它的 WaiOne 实例方法可使当前线程一直处于等待状态，直到接收到某个信号。它的Set方法用于打开发送信号。下面是一个信号机制的使用示例：

static void Main(string[] args) {

    var signal = new ManualResetEvent(false);

    new Thread(() => {
        Console.WriteLine("Waiting for signal...");
        signal.WaitOne();
        signal.Dispose();
        Console.WriteLine("Got signal!");
    }).Start();
    Thread.Sleep(2000);

    signal.Set();// 打开“信号”

    Console.ReadKey();
}

运行结果：

线程详解——c# - 文章图片

当执行Set方法后，信号保持打开状态，可通过Reset方法将其关闭，若不再需要，通过Dispose将其释放。如果预期的等待时间很短，可以用 ManualResetEventSlim代替ManualResetEvent，前者在等待时间较短时性能更好。信号机制非常有用，后面的日志案例会用到它。

线程池中的线程

线程池中的线程是由CLR来管理的。在下面两种条件下，线程池能起到最好的效用：

任务运行的时候比较短（<250ms），这样CLR可以充分调配现有的空闲线程来处理该任务；
大量时间处于等待（或阻塞）的任务不去支配线程池的线程。

要使用线程中的线程，主要有下面两种方式：

// 方式1：Task.Run，.NET Framework 4.5 才有
Task.Run (() => Console.WriteLine ("Hello from the thread pool"));

// 方式2：ThreadPool.QueueUserWorkItem
ThreadPool.QueueUserWorkItem (t => Console.WriteLine ("Hello from the thread pool"));

线程池使得线程可以充分有效地被使用，减少了任务启动的延迟。但是不是所有的情况都适合使用线程池中的线程，比如下面要讲的日志案例 - 异步写文件。

这里讲线程池，是为了让大家大致了解什么时候用线程池中的线程，什么时候不用。即，耗时长或有阻塞情况的不用线程池中的线程。

创建不走线程池中的线程，可以直接通过new Thread来创建，也可以通过下面的代码来创建：

Task task = Task.Factory.StartNew (() => ...,TaskCreationOptions.LongRunning);// 注意必须带TaskCreationOptions.LongRunning参数

这里用到了Task，大家不用关心它，后续博文会详细讲。

关于线程的知识很多，这里不再深入了，因为这些已经足够让我们应付Web开发了。

案例：支持并发的异步日志组件

上文的“并发和异步的区别”的代码中我们用到了一个Logger类，现在我们就来做一个这样的Logger。

基于上面的知识，我们可以实现应用程序的并发写日志日志功能。在应用程序中，写日志是常见的功能，简单分析一下该功能的需求：

在后台异步执行，和其它线程互不影响。
根据上文线程池的两个最优使用条件，由写日志线程会长时间处于阻塞（或运行等待）状态，所以它不适合使用线程池。即不能使用Task.Run，而最好使用new Thread。
支持并发，即多个任务（分布在不同线程上）可同时调用写日志功能，但需保证线程安全。
支持并发，必然要用到锁，但要完全保证线程安全，那就要想办法避免“死锁”。只要我们把“上锁”的操作始终由同一个线程来做即可避免“死锁”问题，但这样的话，并发请求的任务只能放在队列中由该线程依次执行（因为是后台执行，无需即时响应用户，所以可以这么做）。
单个实例，单个线程。
任何地方调用写日志功能都调用的是同一个Logger实例（显然不能每次写日志都新建一个实例），即需使用单例模式。不管有多少任务调用写日志功能，都必须始终使用同一个线程来处理这些写日志操作，以保证不占用过多的线程资源和避免新建线程带来的延迟。

运用上面的知识，我们来写一个这样的类。简单理一下思路：

需要一个用来存放写日志任务的队列。
需要有一个信号机制来标识是否有新的任务要执行。
当有新的写日志任务时，将该任务加入到队列中，并发出信号。
用一个方法来处理队列中的任务，当接收新任务信号时，就依次调用队列中的任务。

开发一个功能前需要有个简单的思路，保证心里面有底。具体开发的时候会发现问题，然后再去补充扩展和完善等。刚开始很难想得太周全，先有个简单的思路，然后代码写起来！

下面是这样一个Logger类初步实现：

public class Logger {

    // 用于存放写日志任务的队列
    private Queue<Action> _queue;

    // 用于写日志的线程
    private Thread _loggingThread;

    // 用于通知是否有新日志要写的“信号器”
    private ManualResetEvent _hasNew;

    // 构造函数，初始化。
    private Logger() {
        _queue = new Queue<Action>();
        _hasNew = new ManualResetEvent(false);

        _loggingThread = new Thread(Process);
        _loggingThread.IsBackground = true;
        _loggingThread.Start();
    }

    // 使用单例模式，保持一个Logger对象
    private static readonly Logger _logger = new Logger();
    private static Logger GetInstance() {
        /* 不安全代码
        lock (locker) {
            if (_logger == null) {
                _logger = new Logger();
            }
        }*/
        return _logger;
    }

    // 处理队列中的任务
    private void Process() {
        while (true) {
            // 等待接收信号，阻塞线程。
            _hasNew.WaitOne();

            // 接收到信号后，重置“信号器”，信号关闭。
            _hasNew.Reset(); 

            // 由于队列中的任务可能在极速地增加，这里等待是为了一次能处理更多的任务，减少对队列的频繁“进出”操作。
            Thread.Sleep(100);

            // 开始执行队列中的任务。
            // 由于执行过程中还可能会有新的任务，所以不能直接对原来的 _queue 进行操作，
            // 先将_queue中的任务复制一份后将其清空，然后对这份拷贝进行操作。

            Queue<Action> queueCopy;
            lock (_queue) {
                queueCopy = new Queue<Action>(_queue);
                _queue.Clear();
            }

            foreach (var action in queueCopy) {
                action();
            }
        }
    }

    private void WriteLog(string content) {
        lock (_queue) { // todo: 这里存在线程安全问题，可能会发生阻塞。
            // 将任务加到队列
            _queue.Enqueue(() => File.AppendAllText("log.txt", content));
        }

        // 打开“信号”
        _hasNew.Set();
    }

    // 公开一个Write方法供外部调用
    public static void Write(string content) {
        // WriteLog 方法只是向队列中添加任务，执行时间极短，所以使用Task.Run。
        Task.Run(() => GetInstance().WriteLog(content));
    }
}

类写好了，用上文“并发和异步的区别”中的代码测试一下这个Logger类，在我的电脑上运行的一次结果：

线程详解——c# - 文章图片

共3000条日志，结果没有问题。

上面的Logger类注释写得很详细，我就不再解析了。

通过这个示例，目的是让大家掌握线程和并发在开发中的基本应用和要注意的问题。

遗憾的是这个Logger类并不完美，而且存在线程安全问题（代码中用红色字体标出），虽然实际环境概率很小。可能上面代码多次运行都很难看到有异常发生（我多次运行未发生异常），但同时再添加几个线程可能就会有问题了。

那么，如何解决这个线程安全问题呢？

内容总结

以上是互联网集市为您收集整理的线程详解——c#全部内容，希望文章能够帮你解决线程详解——c#所遇到的程序开发问题。如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容，请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端

扫描二维码推送至手机访问。

本文链接：https://qyyshop.com/info/617267.html

来源：【匿名】

【上一篇】【C#】文件管理（file类）【下一篇】assemblyinfo.csC#Assembly类访问程序集信息

更多 ►

【线程详解——c#】教程文章相关的互联网学习教程文章

原理最常用的就是C#中 timer类写一个定时方法，然后在把他宿主到windows服务里面。C#中Timer分类关于C# Timer类在C#里关于定时器类就有3个C# Timer使用的方法1.定义在System.Windows.Forms里C# Timer使用的方法2.定义在System.Threading.Timer类里 "C# Timer使用的方法3.定义在System.Timers.Timer类里◆System.Windows.Forms.Timer应用于WinForm中的，它是通过Windows消息机制实现的，类似于VB或Delphi中的Timer控件，内部使用...

C#基础-FileStream实现多线程断点续传【代码】

一、前言网上有许多的多线程断点续传操作，但总是写的很云里雾里，或者写的比较坑长。由于这几个月要负责公司的在线升级项目，所以正好用到代码如下： 1using System;2using System.Collections.Generic;3using System.Linq;4using System.Text;5using System.IO;6using System.Threading;7using System.Threading.Tasks;8 9namespace ConsoleStream10{11class Program12 {13staticvoid Main(string[] args)14 ...

c# 线程信号量 Mutex【代码】

using System; using System.Collections.Generic; using System.Linq; using System.Text;using System.Threading;namespace MyTTCon {class shareRes{publicstaticint count = 0;publicstatic Mutex mutex = new Mutex();}class IncThread{int number;public Thread thrd;public IncThread(string name, int n){thrd = new Thread(this.run);number = n;thrd.Name = name;thrd.Start();}void run(){Console.WriteLine(thrd.Name ...

在C#中如何判断线程当前所处的状态【图】

在C#中如何判断线程当前所处的状态老帅在C#中，线程对象Thread使用ThreadState属性指示线程状态，它是带Flags特性的枚举类型对象，因此判断线程当前的状态必须用bitmask按位运算来达到判断目的，不能直接使用相等来判断。定义ThreadState如下： 1.判断线程是否处于取消状态 A.错误的判断 (MyThread.ThreadState == ThreadState.AbortRequested) B.正确的判断 ...

C#线程【图】

本系列教程主要包括如下内容：1. BeginInvoke和EndInvoke方法2. Thread类3. 线程池4. 线程同步基础5. 死锁6. 线程同步的7种方法7. 如何在线程中访问GUI组件一、线程概述在操作系统中一个进程至少要包含一个线程，然后，在某些时候需要在同一个进程中同时执行多项任务，或是为了提供程序的性能，将要执行的任务分解成多个子任务执行。这就需要在同一个进程中开启多个线程。我们使用C#编写一个应用程序（控制台或桌面程序都可以）...

说说C# 多线程那些事-线程基础【代码】【图】

我第一次接触“线程”的概念时，觉得它深奥难懂，看了好多本书，花了很长时间才领悟到它的真谛。现在我就以一个初学者的心态，把我所理解的“多线程”描述给大家。这一次是系列文章，比较完整的展示与线程相关的基本概念。希望对初学者有所帮助。如果你是高手，请你别继续看，会浪费你宝贵的时间。一、基本概念什么是进程？当一个程序开始运行时，它就是一个进程，进程包括运行中的程序和程序所使用到的内存和系统资源。而一个进程...

C#线程系列讲座(1)：BeginInvoke和EndInvoke方法【图】

l> Normal 0 7.8 磅 0 2 false false false MicrosoftInternetExplorer4 <![endif]--> endif]-->yle> /* Style Definitions */ table.MsoNormalTable { mso-style-parent:""; font-size:10.0pt; font-family:"Times New Roman"; mso-fareast-font-family:"Times New Roman";} <![endif]-->开发语言：C#3.0 IDE：Visual Studio 2008 本系列教程主要包括如下内容： 1. BeginInvoke和EndInvoke方法 2. Thread类 3. 线程池 4. 线程同...

c# 多线程和异步【代码】

有时候需要多线程来运行处理后端和UI的更新。通常用 ((Action)delegate(){if (isBussy) { return; }isBussy = true;while (true){//code long time task.................Dispatcher.BeginInvoke((Action)(delegate(){btnStart.Content = DateTime.Now.ToString();}));Thread.Sleep(300);}isBussy = false;}).BeginInvoke(null, null);原文：https://www.cnblogs.com/wgscd/p/9259742.html

C#多线程（三）【图】

一、线程同步概述在多线程程序中，当存在共享变量和抢占资源的情况时，需要使用线程同步机制来防止发生这些冲突，这样才能保证得到可预见的结果，也就是线程安全的。否则就会出现不可预知的结果产生线程不安全问题。特别是在访问同一个数据的时候最为明显。主要通过以下四个方式进行：简单阻塞：让一个线程等待另一个线程执行结束或者等待一段时间而阻塞执行，使用Sleep、Join、Task.Wait这几个方式构成目的Sleep阻止给定的时间周期...

C#解决“System.Threading.ThreadStateException:“在可以调用 OLE 之前，必须将当前线程设置为单线程单元(STA)模式。请确保您的 Main 函数带有 STAThreadAttribute 标记。只有将调试程序附加到该进程才会引发此异常”的异常【代码】

“System.Threading.ThreadStateException:“在可以调用 OLE 之前，必须将当前线程设置为单线程单元(STA)模式。请确保您的 Main 函数带有 STAThreadAttribute 标记。只有将调试程序附加到该进程才会引发此异常”的异常Thread t = new Thread((ThreadStart)(() => {// 将出现这个异常的语句放到这里面 } )); t.SetApartmentState(ApartmentState.STA); t.Start(); t.Join(); 原文：https://www.cnblogs.com/prodigal-son/p/1420614...

C#线程系列讲座(4)：同步与死锁

虽然线程可以在一定程度上提高程序运行的效率，但也会产生一些副作用。让我们先看看如下的代码： />Code highlighting produced by Actipro CodeHighlighter (freeware) http://www.CodeHighlighter.com/ --> class Increment { private int n = 0; private int max; public Increment(int max) { this.max = max; } public int result { ...

C# 多线程同步和线程通信【代码】【图】

多线程通信1. 当线程之间有先后的依赖关系时，属于线程之间的通信问题。也就是后一个线程要等待别的一个或多个线程全部完成，才能开始下一步的工作。可以使用：WaitHandle Class　　WaitHandle类作为基类来使用的，它允许多个等待操作。这个类封装了win32的同步处理方法。WaitHandle对象通知其他的线程它需要对资源排他性的访问，其他的线程必须等待，直到WaitHandle不再使用资源和等待句柄没有被使用。下面是从它继承来的几个类：...

C# 当前程序所有线程

using System.Linq;var threads = System.Diagnostics.Process.GetCurrentProcess().Threads;var count = threads.Count;var actived = threads.Cast<ProcessThread>().Where(t => t.ThreadState == System.Diagnostics.ThreadState.Running).ToList(); 原文：http://www.cnblogs.com/smartsensor/p/3842320.html

C# 前台线程与后台线程区别【代码】

using System; using System.Drawing; using System.Windows.Forms; using System.Threading;namespace WindowsFormsApplication1 {publicpartialclass Form1 : Form{public Form1(){InitializeComponent();}privatevoid button1_Click(object sender, EventArgs e){//前台线程和后台线程唯一区别就是:应用程序必须运行完所有的前台线程才可以退出；//而对于后台线程，应用程序则可以不考虑其是否已经运行完毕而直接退出，//所有的...

C# 实现多线程的同步方法详解

http://www.cnblogs.com/xugang/archive/2011/03/20/1989782.html原文：http://www.cnblogs.com/wanxun1987/p/3575642.html

C# - 技术教程分类

C# 教程 C# 简介 C# 环境 C# 程序结构 C# 基本语法 C# 数据类型 C# 类型转换 C# 变量 C# 常量 C# 运算符 C# 判断 C# 循环 C# 封装 C# 方法 C# 可空类型 C# 数组（Array） C# 字符串（String） C# 结构体（Struct） C# 枚举（Enum） C# 类（Class） C# 继承 C# 多态性 C# 运算符重载 C# 接口（Interface） C# 命名空间（Namespace） C# 预处理器指令 C# 异常处理 C# 特性（Attribute） C# 反射（Reflection） C# 属性（Property） C# 索引器（Indexer） C# 委托（Delegate） C# 事件（Event） C# 集合（Collection） C# 泛型（Generic） C# 匿名方法 C# 不安全代码 C# 多线程 c# 全部

C# - 最热教程

c#编程连接oracle数据库无法加载DLL(oc...一个适合新手C#程序员编写练习的小项目...C# 异步UDP发送接收数据 C#程序执行时间长和慢查询解决：线程并...c# aspose操作word文档 C#继承讲解以及对象的创建 jquery+ajax+C#实现无刷新操作数据库数...C#精髓 GridView72大绝技学习gridview...c# static的全部用法收集整理 js模拟实现类似c#下的hashtable的简单功...

首页 / C# / 线程详解——c#

线程详解——c#

内容导读

内容图文

线程的简单使用

并发和异步的区别

并发控制 - 锁

线程的信号机制

线程池中的线程

案例：支持并发的异步日志组件

内容总结

内容备注

内容手机端

【线程详解——c#】教程文章相关的互联网学习教程文章

定时任务-C#线程类 windows服务【代码】【图】

C#基础-FileStream实现多线程断点续传【代码】

c# 线程信号量 Mutex【代码】

在C#中如何判断线程当前所处的状态【图】

C#线程【图】

说说C# 多线程那些事-线程基础【代码】【图】

C#线程系列讲座(1)：BeginInvoke和EndInvoke方法【图】

c# 多线程和异步【代码】

C#多线程（三）【图】

C#解决“System.Threading.ThreadStateException:“在可以调用 OLE 之前，必须将当前线程设置为单线程单元(STA)模式。请确保您的 Main 函数带有 STAThreadAttribute 标记。只有将调试程序附加到该进程才会引发此异常”的异常【代码】

C#线程系列讲座(4)：同步与死锁

C# 多线程同步和线程通信【代码】【图】

C# 当前程序所有线程

C# 前台线程与后台线程区别【代码】

C# 实现多线程的同步方法详解

C# - 技术教程分类

C# - 最新教程

C# - 最热教程