C#多线程之旅(2)——详解线程的开始和创建

阅读目录

  • 代码下载
  • 一、线程的创建和开始
  • 二、传递数据给一个线程
  • 三、命名线程
  • 四、前台线程和后台线程
  • 五、线程优先级
  • 六、异常处理

 

代码下载

Thread_博客园_cnblogs_jackson0714.zip

第一篇~第三篇的代码示例:

源码地址:https://github.com/Jackson0714/Threads

 

回到顶部

一、线程的创建和开始

在第一篇的介绍中,线程使用Thread 类的构造函数来创建,通过传给一个ThreadStart 委托来实现线程在哪里开始执行。下面是ThreadStart的定义:

// Summary:
//     Represents the method that executes on a System.Threading.Thread.
[ComVisible(true)]
public delegate void ThreadStart();

调用一个Start方法,然后设置它开始运行。线程会一直运行直到这个方法返回,然后这个线程结束。

下面是一个例子,使用扩展C#语法创建一个ThreadStart委托:2.1_ThreadStart

 

 1 class ThreadTest2 {3     static void Main()4     {5         Thread t = new Thread(new ThreadStart(Go));6         t.Start(); 7         Go();8         Console.ReadKey();9     }
10     static void Go()
11     {
12         Console.WriteLine("hello!");
13     }
14 }

 

在这个例子中,thread t执行Go(),基本上与主线同时程调用Go()方法,结果是打印出两个时间接近的hello。

一个线程可以被方便的创建通过指定一个方法组,然后由C#推断出ThreadStart委托:2.2_Thread

 

 1 class Program2 {3     static void Main(string[] args)4     {5         Thread t = new Thread(Go);6         t.Start();7         Go();8         Console.ReadKey();9     }
10 
11     static void Go()
12     {
13         Console.WriteLine("Go");
14     }
15 }

复制代码

另外一种更简单的方式是使用lambda表达式或者匿名方法:2.3_LambaExpression

复制代码

static void Main(string[] args)
{Thread t = new Thread(()=>Console.WriteLine("Go"));t.Start();Console.ReadKey();
}

复制代码

回到顶部

二、传递数据给一个线程

1.利用Lambda传递一个数据

传递参数给线程的目标方法的最简单的方法是执行一个lambda表达式,该表达式调用一个方法并传递期望的参数给这个方法。

2.4_PassingDataToAThread

复制代码

static void Main(string[] args)
{Thread t = new Thread(() => Print("A"));t.Start();Console.ReadKey();
}static void Print(string message)
{Console.WriteLine(message);
}

 

2.传递多个参数

通过这种方式,你可以传递任意数量的参数给这个方法。你甚至可以将整个实现包装在一个多语句的lambda中:

2.5_PassingDataToAThread

new Thread(() =>
{Console.WriteLine("a");Console.WriteLine("b");
}).Start();

你也可以简单的在C# 2.0里面那样使用匿名方法做同样的事:

new Thread(delegate()
{Console.WriteLine("a");Console.WriteLine("b");
}).Start();

3.利用Thread.Start传递参数

另外一种方式是传递一个参数给ThreadStart方法:

2.6_PassingDataToAThread_ThreadStart

static void Main(string[] args)
{Thread t = new Thread(Print);t.Start("A");Console.ReadKey();
}
static void Print(object messageObj)
{string message = (string)messageObj;//必须进行转换Console.WriteLine(message);
}

 

这种方式能够工作是因为Thread的构造函数是重载的,接受下面两种中的任意一种委托:

 

// Summary:
//     Represents the method that executes on a System.Threading.Thread.
[ComVisible(true)]
public delegate void ThreadStart();// Summary:
//     Represents the method that executes on a System.Threading.Thread.
//
// Parameters:
//   obj:
//     An object that contains data for the thread procedure.
[ComVisible(false)]
public delegate void ParameterizedThreadStart(object obj);

复制代码

这个ParameterizedThreadStart的只允许接收一个参数。而且因为它的类型是object,所以通常需要转换。

4.Lambda表达式和捕获变量

由我们上面看到的例子可以知道,一个lambda式在传递数据给线程是最用的。然而,你必须非常小心在开始线程后意外修改捕获变量,因为这些变量是共享的。比如下面的:

2.7_LbdaExpressionsAndCapturedVariables

for(int i =0;i<10;i++)
{new Thread(() => Console.Write(i)).Start();
}

这个输出是不确定的,下面是一种典型的情况:

这里的问题是变量i在for循环执行时指向同一个内存地址。因此,每一个线程调用Console.Write时,i的值有可能在这个线程运行时改变。

解决方案是使用一个临时变量:

2.8_LambdaExpressionsAndCapturedVariables_Solution

for (int i = 0; i < 10; i++)
{int temp = i;new Thread(() => Console.Write(temp)).Start();
}

变量temp在每个循环迭代中位于不同的内存块。因此每一个线程捕获到了不同的内存位置,而且没有问题。我们可以解释在之前的代码中的问题:

2.9_PassingData_TemporaryVariable

复制代码

string text = "A";
Thread a = new Thread(() => Console.WriteLine(text));text = "B";
Thread b = new Thread(() => Console.WriteLine(text));a.Start();
b.Start();

复制代码

因为两个lambda表达式捕获同样的text的值,所以B被打印出两次。

回到顶部

三、命名线程

每一个线程有一个Name属性你可以方便用来debugging.当线程显示在Visual Statudio里面的Threads Window和Debug Loaction toolbar的时候,线程的Name属性是特别有用的。你可以只设置线程的名字一次;之后尝试改变它将会抛出异常信息。

静态的Thread.CurrentThread属性代表当前执行的线程。

在下面的例子2.10_NamingThread中,我们设置了主线程的名字:

复制代码

static void Main(string[] args)
{Thread.CurrentThread.Name = "Main Thread";Thread t = new Thread(Go);t.Name = "Worker Thread";t.Start();Go();Console.ReadKey();
}
static void Go()
{Console.WriteLine("Go! The current thread is {0}", Thread.CurrentThread.Name);
}

复制代码

回到顶部

四、前台线程和后台线程

默认情况下,你自己显示创建的线程是前台线程。前台线程保持这个应用程序一直存活只要其中任意一个正在运行,而后台线程不是这样的。一旦所有的前台线程完成,这个应用程序就结束了, 任何正在运行的后台线程立刻终止。

一个线程前台/后台的状态跟它的优先级和配置的执行时间没有关联。

你可以使用线程的IsBackgroud属性查询或改变一个线程的后台状态。

下面是例子:2.11_PriorityTest

复制代码

static void Main(string[] args)
{Thread t = new Thread(() => Console.ReadKey());if (args.Length > 0)//如果Main方法没有传入参数{//设置线程为后台线程,等待用户输入。//因为主线程在t.Start()执行之后就会终止,//所以后台线程t会在主线程退出之后,立即终止,应用程序就会结束。t.IsBackground = true;}t.Start();
}

复制代码

如果程序调用的时候传入了参数,则创建的线程为前台线程,然后等待用户输入。

同时,如果主线程退出,应用程序将不会退出,因为前台线程t没有退出。

另一方面,如果main方法传入了参数,则创建的线程设置为后台线程。当主线程退出时,应用程序立即退出。

当一个进程以这种方式终止,则任何后台线程执行栈里面的finally 语句块将会被规避。

如果你的线程使用finally(or using)语句块去执行如释放资源或者删除临时文件的清理工作,这将是一个问题。为了避免这个,你可以显示地等待后台线程退出应用程序。

这里有两种实现方式:

  1. 如果你自己创建了这个线程,可以在这个线程上调用Join方法。
  2. 如果你使用线程池,可以使用一个事件去等待处理这个线程。

在这两种情况下,你需要指定一个timeout,因此可以结束一个由于某些原因拒绝完成的线程。这是你的备选退出策略:在最后,你想要你的应用程序关闭,不需要用户从任务管理器中删除。

如果用户使用任务管理器强制结束一个.NET进程,所有的线程像是后台线程一样终止。这个是观察到的行为,所以会因为CLR和操作系统的版本而不同。

前台线程不需要这样对待,但是你必须小心避免可能造成线程不能结束的bugs。造成应用程序不能正确地退出的一个通常的原因是有激活的前台线程还存活在。

回到顶部

五、线程优先级

一个线程的优先级决定了在操作系统中它可以得到多少相对其他线程的执行时间,下面是线程优先级的等级:

复制代码

// Summary:
//     Specifies the scheduling priority of a System.Threading.Thread.
[Serializable]
[ComVisible(true)]
public enum ThreadPriority
{Lowest = 0,BelowNormal = 1,Normal = 2,AboveNormal = 3,Highest = 4,
}

复制代码

当多线程同时是激活的,线程优先级是很重要的。

注意:提高线程优先级时,需要非常小心,这将可能导致其他线程对资源访问的饥饿状态的问题。

当提升一个线程的优先级时,不会使它执行实时工作,因为它被应用程序的进程优先级限制了。为了执行实时工作,你也必须通过使用System.Diagnostices的Process类来提升进程的优先级:

using (Process p = Process.GetCurrentProcess())
{p.PriorityClass = ProcessPriorityClass.High;
}

ProcessPriorityClass.High事实上是优先级最高的一档:实时。设置一个进程优先级到实时状态将会导致其他线程无法获得CPU时间片。如果你的应用程序意外地进入一个无限循环的状态,你甚至会发现操作被锁住了,只有电源键能够拯救你了。针对这个原因,High通常对于实时应用程序是最好的选择。

如果你的实时应用程序有一个用户界面,提高程序的优先级将会使刷新界面占用昂贵的CPU的时间,且会使整个系统变得运行缓慢(尤其是UI很复杂的时候)。降低主线程优先级且提升进程的优先级来确保实时线程不会被界面重绘所抢占,但是不会解决其他进程对CPU访问缺乏的问题,因为操作系统整体上会一直分配不成比例的资源给进程。一个理想的解决方案是让实时线程和用户界面用不同的优先级运行在不同的进程中,通过远程和内存映射文件来通信。即使提高了进程优先级,在托管环境中处理硬实时系统需求还是对适用性有限制。此外,潜藏的问题会被自动垃圾回收引进,操作系统会遇到新的挑战,即使是非托管代码,使用专用硬件或者特殊的实时平台,那将被最好的解决。

回到顶部

六、异常处理

在任何try/catch/finally 语句块作用域内创建的线程,当这个线程开始时,这个线程和语句块是没有关联的。

思考下面的程序:

 参考例子:2.12_ExceptionHandling

复制代码

static void Main(string[] args)
{try{new Thread(Go).Start();}catch(Exception ex){Console.WriteLine("Exception");}Console.ReadKey();
}
static void Go()
{throw null;
}

复制代码

try/catch 声明在这个例子中是无效的,而且新创建的线程将会被一个未处理的NullReferenceException所阻断。当你考虑每一个线程有一个单独的执行路径这种行为是说得通的。

改进方法是将exception handler移到Go()的方法中:

参考例子:2.13_ExceptionHandling_Remedy

复制代码

class Program
{static void Main(string[] args){new Thread(Go).Start();Console.ReadKey();}static void Go(){try{throw null;}catch (Exception ex){Console.WriteLine(ex.Message);}}
}

复制代码

你需要在应用程序中的所有线程入口方法中添加一个exception handler ,就像你在主线程中做的那样。一个未处理的线程会造成整个应用程序关闭,而且会弹出一个不好看的窗口。

在写这个exception handling 语句块时,你可能极少忽略这个问题,典型情况是,你可能会记录exception的详细信息,然后可能显示一个窗口让用户去自动去提交这些信息到你的web server上。然后你可能会关掉这个应用程序-因为这个error毁坏了程序的状态。然后,这样做的开销是用户可能会丢失他最近的工作,比如打开的文档。

对于WPF和WinForm应用程序来说,全局的exception handling 事件(Application.DispatcherUnhandlerException 和Application.ThreadException)只会检测到主UI线程上的抛出的异常。你还是必须手动处理线程的异常。

AppDomain.CurrentDomain.UnhandledException可以检测任何未处理的异常,但是无法阻止应用程序之后关闭。

然而,某些情形下你不需要在线程上处理异常,因为.NET Framework为你做了这个。下面是没有提及的内容:

Asynchronous delegates

BackgroudWorker

The Task Parallel Library(conditions apply)

 

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/438228.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

C#多线程之旅(3)——线程池

阅读目录 代码下载一、介绍二、通过TPL进入线程池三、不用TPL进入到线程池v博客前言 先交代下背景&#xff0c;写《C#多线程之旅》这个系列文章主要是因为以下几个原因&#xff1a;1.多线程在C/S和B/S架构中用得是非常多的;2.而且多线程的使用是非常复杂的&#xff0c;如果没有…

Spring Cloud是什么

Spring Cloud是一系列框架的有序集合。它利用Spring Boot的开发便利性巧妙地简化了分布式系统基础设施的开发&#xff0c;如服务发现注册、配置中心、消息总线、负载均衡、断路器、数据监控等&#xff0c;都可以用Spring Boot的开发风格做到一键启动和部署。Spring Cloud并没有…

C#多线程之旅(4)——APM初探

阅读目录 一、简单的串行执行程序 二、使用委托来实现APM源码地址&#xff1a;https://github.com/Jackson0714/Threads C#多线程之旅(4)——APM初探 v博客前言 先交代下背景&#xff0c;前面几张内容主要是介绍多线程的基本知识&#xff0c;这一章是因为正好接触到了APM&…

阿里巴巴消息中间件: Spring Cloud Stream

Spring Cloud Stream是一个框架&#xff0c;用于构建与共享消息传递系统连接的高度可扩展的事件驱动微服务。 该框架提供了一个灵活的编程模型&#xff0c;该模型基于已经建立和熟悉的Spring习语和最佳实践&#xff0c;包括对持久性发布/订阅语义&#xff0c;消费者组和有状态…

C#多线程编程系列(五)- C# ConcurrentBag的实现原理

目录 一、前言二、ConcurrentBag类三、 ConcurrentBag线程安全实现原理 1. ConcurrentBag的私有字段2. 用于数据存储的ThreadLocalList类3. ConcurrentBag实现新增元素4. ConcurrentBag 如何实现迭代器模式四、总结笔者水平有限&#xff0c;如果错误欢迎各位批评指正&#xff…

Spring Boot 常用注解

SpringBootApplication 查看源码可发现&#xff0c;SpringBootApplication是一个复合注解&#xff0c;包含了SpringBootConfiguration&#xff0c;EnableAutoConfiguration&#xff0c;ComponentScan这三个注解 SpringBootConfiguration 注解&#xff0c;继承Configuration注…

C#多线程编程系列(五)- 浅析C# Dictionary实现原理

目录 一、前言二、理论知识 1、Hash算法2、Hash桶算法3、解决冲突算法三、Dictionary实现 1. Entry结构体2. 其它关键私有变量3. Dictionary - Add操作4. Dictionary - Find操作5. Dictionary - Remove操作6. Dictionary - Resize操作(扩容)7. Dictionary - 再谈Add操作8. Col…

Java中的list、set、map区别

List 有序,可重复 ArrayList 优点: 底层数据结构是数组&#xff0c;查询快&#xff0c;增删慢。 缺点: 线程不安全&#xff0c;效率高 Vector 优点: 底层数据结构是数组&#xff0c;查询快&#xff0c;增删慢。 缺点: 线程安全&#xff0c;效率低 LinkedList 优点: 底层数据结…

ASP.NET MVC 入门5、View与ViewData

本系列文章基于ASP.NET MVC Preview5. view在MVC模式中与用户进行最直接的接触&#xff0c;它负责数据的呈现。这里要注意一点就是&#xff0c;view只是负责数据的呈现&#xff0c;所以我们应该要尽量让view中不涉及业务逻辑的处理。 我们来添加一个Blog首页的view。在安装了…

ASP.NET MVC 入门6、TempData

本系列文章基于ASP.NET MVC Preview5. ASP.NET MVC的TempData用于传输一些临时的数据&#xff0c;例如在各个控制器Action间传递临时的数据或者给View传递一些临时的数据&#xff0c;相信大家都看过“在ASP.NET页面间传值的方法有哪几种”这个面试题&#xff0c;在ASP.NET MVC…

ASP.NET MVC 入门11、使用AJAX

本系列文章基于ASP.NET MVC beta.本示例Blog系统同步更新的演示站点&#xff1a;http://4mvcblog.qsh.in/ 在ASP.NET MVC beta发布之前&#xff0c;M$就宣布支持开源的JS框架jQuery&#xff0c;然后ASP.NET MVC beta发布后&#xff0c;你建立一个ASP.NET MVC beta的项目后&…

.NET三种异步模式(APM、EAP、TAP)

APM模式&#xff1a; .net 1.0时期就提出的一种异步模式&#xff0c;并且基于IAsyncResult接口实现BeginXXX和EndXXX类似的方法。 .net中有很多类实现了该模式(比如HttpWebRequest)&#xff0c;同时我们也可以自定义类来实现APM模式(继承IAsyncResult接口并且实现BeginXXX和E…

Nacos 使用

环境准备 64 bit OS&#xff0c;支持 Linux/Unix/Mac/Windows&#xff0c;推荐选用 Linux/Unix/Mac。64 bit JDK 1.8&#xff1b;下载 & 配置。Maven 3.2.x&#xff1b;下载 & 配置。 下载 Nacos 并启动 Nacos server。 启动配置管理 启动了 Nacos server 后&#x…

四种并发编程模型简介

概述 并发往往和并行一起被提及&#xff0c;但是我们应该明确的是“并发”不等同于“并行” • 并发 &#xff1a;同一时间 对待 多件事情 &#xff08;逻辑层面&#xff09; • 并行 &#xff1a;同一时间 做(执行) 多件事情 (物理层面) 并发可以构造出一种问题解…

easyexcel操作Excel导入导出

需要添加maven依赖 <dependency><groupId>com.alibaba</groupId><artifactId>easyexcel</artifactId><version>3.0.5</version></dependency> 读Excel package com.alibaba.easyexcel.test.demo.read;import java.io.File; …

从编译到执行,C++如何开发SIMD友好的代码?

一&#xff1a;名词解释 Flynn分类法 Flynn于1972年提出了计算平台的Flynn分类法,主要根据指令流和数据流来分类。按照Flynn分类法&#xff0c;计算平台共分为四种类型。 1.单指令流单数据流机器(SISD) 2.单指令流多数据流机器(SIMD) 3.多指令流单数据流机器(MISD) 4.多指令流…

Nacos介绍

Nacos 英文全称为 Dynamic Naming and Configuration Service&#xff0c;是一个由阿里巴巴团队使用 Java 语言开发的开源项目。 参考:home (nacos.io) Nacos 是一个更易于帮助构建云原生应用的动态服务发现、配置和服务管理平台&#xff0c;可以将 Nacos 理解成服务注册中心…

在部署 C#项目时转换 App.config 配置文件

问题 部署项目时&#xff0c;常常需要根据不同的环境使用不同的配置文件。例如&#xff0c;在部署网站时可能希望禁用调试选项&#xff0c;并更改连接字符串以使其指向不同的数据库。在创建 Web 项目时&#xff0c;Visual Studio 自动生成了 Web.config、Web.Debug.config、We…

@Transactional

事务场景中&#xff0c;抛出异常被catch后&#xff0c;如果需要回滚&#xff0c;一定要手动回滚事务。 Spring事务框架默认只在抛出RuntimeException和unchecked exceptions时才将事务回滚&#xff08;Errors默认 - 事务回滚&#xff09;&#xff0c;但是抛出的Checked except…

设计模式之Factory

设计模式之Factory 2016-08-04 11:57 设计模式总共有23种模式这种都仅仅是为了一个目的&#xff1a;解耦解耦解耦...&#xff08;高内聚低耦合满足开闭原则&#xff09; 介绍: Factory Pattern有3种当然是全部是creational pattern。 1.Simple Factory Pattern 2.Factory…