[C# 线程处理系列]专题二：线程池中的工作者线程

**引言：**

最近一段时间都在研究关于.Net线程的内容，觉得线程是每个程序员都应该掌握的，所以写下这个线程的系列希望能给大家学习过程中一些帮助，同时也是自己对线程的巩固，当中如果有什么错漏还请大家指出，这样我们可以互相得到进步。



**目录**：

一、线程的介绍 
二、线程调度和优先级 
三、前台线程和后台线程 
四、简单线程的使用 

**一、线程的介绍**

在介绍线程之前， 很有必要知道什么是进程，以及与线程的关系。 
**进程**(Process)是应用程序的实例要使用的**资源**的一个集合（从可以简化理解：进程就是一种**资源**，是应用程序所用的资源）。每个应用程序都在各自的进程中运行来确保应用程序不受其他应用程序的影响，如果一个应用程序失败了， 只会影响自己的进程，其他进程中的应用程序可以继续运行。进程是操作系统为我们提供的一种保护应用程序的一种机制。 
**线程**是进程中基本执行单元， 一个进程中可以包含多个线程，在进程入口执行的第一个线程是一个进程的主线程，在.Net应用程序中，都是以Main()方法作为程序的入口的， 所以在程序运行过程中调用这个方法时，系统就会自动创建一个主线程。（他们之间的关系简单说：线程是进程的执行单元，进程是线程的一个容器了）。

**二、线程调度和优先级**

Windows之所以被称为抢占式多线程操作系统，是因为线程可以在任意时间被抢占，并调度另一个线程。每个线程都分配了从0~31的一个优先级。系统首先把高优先级的线程分配给CPU执行。Windows 支持7个相对线程优先级：Idle,Lowest,Below Normal,Normal,Above Normal,Highest和Time-Critical,Normal是默认的线程优先级，然而在程序中可以通过设置Thread的Priority属性来改变线程的优先级，它的类型为ThreadPriority枚举类型，包含枚举有：Lowest,BelowNormal,Normal,AboveNormal和Highest,CLR为自己保留了 Idle和Time-Critical优先级。具体每个枚举值含义如下表：

| 成员名称 | 说明 |
| --- | --- |
| Lowest | 可以将 Thread何其他优先级的线程之后。 |
| BelowNormal | 可以将 Thread Normal 优先级的线程之后，在具有 Lowest 优先级的线程之前。 |
| Normal | 可以将 Thread AboveNormal 优先级的线程之后，在具有 BelowNormal 优先级的线程之前。 默认情况下，线程具有 Normal 优先级。 |
| AboveNormal | 可以将 Thread Highest 优先级的线程之后，在具有 Normal 优先级的线程之前。 |
| Highest | 可以将 Thread 其他优先级的线程之前。 |

**三、前台线程和后台线程**

在.net中线程分为前台线程和后台线程，在一个进程中，当所有前台线程停止运行时，CLR会强制结束仍在运行的任何后台线程，这些后台线程直接被终止，不会抛出异常。 所以我们应该在前台线程中执行我们确实要完成的事情，另外， 应该把非关键的任务使用后台线程，我们用Thread创建的是线程为前台线程。让我们通过下面的一段代码来看看前台线程和后台线成的区别：

``` C#
using System;
using System.Threading;

class Program
{
 static void Main(string[] args)
 {
 // 创建一个新线程（默认为前台线程）
 Thread backthread = new Thread(Worker);

 // 使线程成为一个后台线程
 backthread.IsBackground = true;

 // 通过Start方法启动线程
 backthread.Start();

 // 如果backthread是前台线程，则应用程序大约5秒后才终止
 // 如果backthread是后台线程，则应用程序立即终止
 Console.WriteLine("Return from Main Thread");
 }
 private static void Worker()
 {
 // 模拟做10秒
 Thread.Sleep(5000);

 // 下面语句，只有由一个前台线程执行时，才会显示出来
 Console.WriteLine("Return from Worker Thread");
 }
}
```

运行上面代码可以发现：控制台中显示字符串: Return form Main Thread 后就退出了， 字符串 Return from Worker Thread字符串根本就没有显示，这是因为此时的backthread线程为后台线程，当主线程（执行Main方法的线程，主线程当然也是前台线程了）结束运行后，CLR会强制终止后台线程的运行，整个进程就被销毁了，并不会等待后台线程运行完后才销毁。如果把 backthread.IsBackground = true; 注释掉后， 就可以看到控制台过5秒后就输出 Return from Worker Thread。再在Worker方法最后加一句 代码：Console.Read(); 就可以看到这样的结果了：


![image.png](https://cdn.netclub.top/images/233bfdcbd383219e28480a7adfecaa46.image.webp?imageslim)

**注意**：有些人可能会问我不想把 backthread.IsBackground = true;注释掉， 又想把Worker()方法中的字符串输出在控制台上怎么做呢？ 其实是有解决的办法的， 我们可以调用thread.Join()方法来实现，Join()方法能保证主线程（前台线程）在异步线程thread（后台线程）运行结束后才会运行。 
实现代码如下：

``` C#
using System;
using System.Threading;
class Program
{
 static void Main(string[] args)
 {
 // 创建一个新线程（默认为前台线程）
 Thread backthread = new Thread(Worker);

 // 使线程成为一个后台线程
 backthread.IsBackground = true;

 // 通过Start方法启动线程
 backthread.Start();
 backthread.Join();

 // 模拟主线程的输出
 Thread.Sleep(2000);

 Console.WriteLine("Return from Main Thread");
 Console.Read();
 }

 private static void Worker()
 {
 // 模拟做3秒
 Thread.Sleep(3000); 

 // 下面语句，只有由一个前台线程执行时，才会显示出来
 Console.WriteLine("Return from Worker Thread");

 }
}
```

运行结果（调用Join方法后后台线程会阻塞主线程所以主线程会后输出）：

**四、简单线程的使用**

其实在上面介绍前台线程和后台线程的时候已经通过ThreadStart委托创建了一个线程了，此时已经实现了一个多线程的一个过程，为此系列中将多线程也是做一个铺垫吧。下面通过**ParameterizedThreadStart**委托的方式来实现多线程。 
以**ParameterizedThreadStart**委托的方式来实现多线程：

``` C#
using System;
using System.Threading;
class Program
{
 static void Main(string[] args)
 {
// 创建一个新线程（默认为前台线程）
 Thread backthread = new Thread(new ParameterizedThreadStart(Worker));

 
 // 通过Start方法启动线程
 backthread.Start("123");

 // 如果backthread是前台线程，则应用程序大约5秒后才终止
 // 如果backthread是后台线程，则应用程序立即终止
 Console.WriteLine("Return from Main Thread");
 }

 private static void Worker(object data)
 {
 // 模拟做5秒
 Thread.Sleep(5000);

 // 下面语句，只有由一个前台线程执行时，才会显示出来
 Console.WriteLine(data + " Return from Worker Thread");
 Console.Read();
 }
}
```

注意：此时Worker方法传入了一个参数，并且Start方法也传递了一个字符传参数。 对比与之前创建Thread的不同， 运行结果为：

![image.png](https://cdn.netclub.top/images/16288cb74f34227f8a94df4a729289c9.image.webp?imageslim)

写到这里， 本系列的第一篇差不多讲完了，在后续的文章将会介绍Thread方法的使用以及通过一些例子来展示他们的不同之处（像Abort()方法Interrupt方法等）对于线程的一些高级使用（如线程池，并行编程和PLINQ、线程同步和计时器）都会在后续中讲到。希望本系列可以给初学线程的人有所帮助。

> 来自: [[C# 线程处理系列]专题一：线程基础 - Learning hard - 博客园](https://www.cnblogs.com/zhili/archive/2012/07/18/Thread.html)

[C# 线程处理系列]专题一：线程基础

> [hub.docker](https://hub.docker.com/)
> [SkyAPM](https://github.com/SkyAPM/SkyAPM-dotnet)

### 1、使用 Docker 安装 Elaticsearch
> ES_JAVA_OPTS="-Xms128m -Xmx512m"
> 用于解决内存太小的问题



```csharp
docker pull elasticsearch:7.8.0
docker run -d --name=es7 -p 9200:9200 -p 9300:9300 -e ES_JAVA_OPTS="-Xms128m -Xmx512m" -e "discovery.type=single-node" elasticsearch:7.8.0
```

### 2、安装 Apache/SkyWalking-oap-server
```csharp
docker pull apache/skywalking-oap-server:8.3.0-es7
docker run --name oap -d --restart=always -e TZ=Asia/Shanghai -p 12800:12800 -p 11800:11800 --link es7:es7 -e SW_STORAGE=elasticsearch7 -e SW_STORAGE_ES_CLUSTER_NODES=es7:9200 apache/skywalking-oap-server:8.3.0-es7
```

### 3、下载Skywalking-ui
```csharp
docker pull apache/skywalking-ui:8.3.0
docker run -d --name skywalking-ui --restart=always -e TZ=Asia/Shanghai -p 8080:8080 --link oap:oap -e SW_OAP_ADDRESS=oap:12800 apache/skywalking-ui:8.3.0
```

![image.png](https://cdn.netclub.top/images/27345f529f4417dad4cc87a8a8ea0ee4.image.webp?imageslim)

### 4、访问 localhost:8080 查看 Skywalking 管理界面

![image.png](https://cdn.netclub.top/images/f3b6e6378fb8a6222625fcbb5778ff1e.image.webp?imageslim)

### 5、Net5 集成 SkyWalking
借用上篇文章 [Net5 使用Ocelot+Consul](https://netclub.top/post/14) 
在`Gateways`、`App.Gateways`中加入包 `SkyAPM.Agent.AspNetCore`，版本`1.3.0`，同时加入`skyapm.json` 文件，并设置属性为`较新则复制` `launchSettings.json` 中添加环境变量

```csharp
"SKYWALKING__SERVICENAME": "AppGateWay/ApiGateway",
"ASPNETCORE_HOSTINGSTARTUPASSEMBLIES": "SkyAPM.Agent.AspNetCore"
```

![image.png](https://cdn.netclub.top/images/c246bbc079ee0890325ab7f96d05b158.image.webp?imageslim)

```csharp
// Programs 文件
.ConfigureAppConfiguration(builder =>
{
 builder.AddJsonFile("ocelot.json", false, true)
 .AddJsonFile("skyapm.json", false, true);
})
```
```json
// Gateways
{
 "SkyWalking": {
 "ServiceName": "ApiGateWay",
 "Namespace": "",
 "HeaderVersions": [
 "sw8"
 ],
 "Sampling": {
 "SamplePer3Secs": -1,
 "Percentage": -1.0
 },
 "ServiceInstanceName": "ApiGateWay.001",
 "Logging": {
 "Level": "Information",
 "FilePath": "logs\\skyapm-{Date}.log"
 },
 "Transport": {
 "Interval": 3000,
 "ProtocolVersion": "v8",
 "QueueSize": 30000,
 "BatchSize": 3000,
 "gRPC": {
 "Servers": "192.168.2.17:11800",
 "Timeout": 10000,
 "ConnectTimeout": 10000,
 "ReportTimeout": 600000,
 "Authentication": ""
 }
 }
 }
}

// App.Gateways
{
 "SkyWalking": {
 "ServiceName": "AppGateWay",
 "Namespace": "",
 "HeaderVersions": [
 "sw8"
 ],
 "Sampling": {
 "SamplePer3Secs": -1,
 "Percentage": -1.0
 },
 "ServiceInstanceName": "ApiGateWay.002",
 "Logging": {
 "Level": "Information",
 "FilePath": "logs\\skyapm-{Date}.log"
 },
 "Transport": {
 "Interval": 3000,
 "ProtocolVersion": "v8",
 "QueueSize": 30000,
 "BatchSize": 3000,
 "gRPC": {
 "Servers": "192.168.2.17:11800",
 "Timeout": 10000,
 "ConnectTimeout": 10000,
 "ReportTimeout": 600000,
 "Authentication": ""
 }
 }
 }
}
```
![image.png](https://cdn.netclub.top/images/c8f62b7f243e2c430b077c7a2912c494.image.webp?imageslim) 

![image.png](https://cdn.netclub.top/images/b6ae9202b1c27d7da52d9a97ec9beede.image.webp?imageslim)
### 6、参考资料
[https://www.cnblogs.com/jianghaidong/p/15693935.html](https://www.cnblogs.com/jianghaidong/p/15693935.html)

Net5集成SkyWalking8

> 环境： 
> VS2022 
> Docker 
> Ocelot.Provider.Consul 17.0.1

### 1、Windows 安装 Consul
[官网](https://www.consul.io/downloads) 将下载好的压缩包放到某个文件夹下，cd 定位到这个目录，运行
```csharp
# Development
consul agent -dev -ui -node=cy
```



### 2、新建三个 WebAPI
```csharp
dotnet new webapi -n Gateways -f net5（网关1）
dotnet new webapi -n App.Gateways -f net5（网关2）
dotnet new webapi -n App.ApiAggregator -f net5

dotnet new sln 
dotnet sln add .\Gateways
dotnet sln add .\App.Gateways
dotnet sln add .\App.ApiAggregator

# Gateways 和 App.Gateways 添加包
Ocelot.Provider.Consul

# 修改启动端口
Gateways：6001
App.Gateways：6002
App.ApiAggregator：6004
```
`Gateways` 和 `App.Gateways` 集成 `Ocelot`
```csharp
# ConfigureServices
services.AddOcelot(Configuration).AddConsul();

# 在 Configure 方法最后面加入
app.UseOcelot().Wait();
```
`Gateways` 加入 `Ocelot.json` 文件，并修改属性为 `如果较新则复制`
```json
{
 "GlobalConfiguration": {
 "RequestIdKey": "OcRequestId",
 "AdministrationPath": "/administration"
 },
 "Routes": [
 {
 "DownstreamPathTemplate": "/api/{everything}",
 "DownstreamScheme": "http",
 "DownstreamHostAndPorts": [
 {
 "Host": "localhost",
 "Port": 6004
 }
 ],
 "UpstreamPathTemplate": "/mobileAgg/api/{everything}",
 "UpstreamHttpMethod": []
 },
 {
 "DownstreamPathTemplate": "/api/{everything}",
 "DownstreamScheme": "http",
 "DownstreamHostAndPorts": [
 {
 "Host": "localhost",
 "Port": 6002
 }
 ],
 "UpstreamPathTemplate": "/mobile/api/{everything}",
 "UpstreamHttpMethod": []
 }
 ]
}

```
将 `JSON` 文件复制一份到 `App.Gateways` ，并修改属性为 `如果较新则复制`，修改 `6002` 为 `6001`。 `Gateways` 和 `App.Gateways`，`Program` 文件加入
```csharp
.ConfigureAppConfiguration(builder =>
{
 builder.AddJsonFile("ocelot.json", false, true);
})
```
在三个API项目中新建 ConsulExtensions 类，三个文件中的 port 分别对应启动端口，在 ConfigureService 方法中加入
```csharp
services.UseConsul();
```
> 注意：`ConsulClient` 中的地址如果为本地开发环境，需为`localhost`，ip地址也一样

```csharp
public static class ConsulExtension
{
 public static void UseConsul(this IServiceCollection services)
 {
 if (services == null)
 throw new ArgumentNullException(nameof(services));

 var client = new ConsulClient(m =>
 {
 m.Address = new Uri("http://localhost:8500");
 m.Datacenter = "dc1";
 });

 string ip = "localhost";
 int port = 6001;
 client.Agent.ServiceRegister(new AgentServiceRegistration
 {
 ID = "Gateway",
 Name = "Gateway",
 Port = port,
 Address = ip,
 Check = new AgentServiceCheck
 {
 Interval = TimeSpan.FromSeconds(5),
 HTTP = $"http://{ip}:{port}/api/Health",
 Timeout = TimeSpan.FromSeconds(5),
 DeregisterCriticalServiceAfter = TimeSpan.FromSeconds(5)
 }
 });
 Console.WriteLine($"http://{ip}:{port}/api/Health");
 }
}
```
在三个API项目中新建控制器 `HealthController`，用于健康检查，三个控制器分别返回 `6001-Gateways`，`6002-Gateways`，`6004-App.ApiAggregator`
```csharp
[Route("api/[controller]")]
[ApiController]
public class HealthController : ControllerBase
{
 [HttpGet]
 public IActionResult Get()
 {
 Console.WriteLine("Gateways");
 return Ok("6001-Gateways");
 }
}
```

![image.png](https://cdn.netclub.top/images/08958359b00298e8ec07096203bcbb8d.image.webp?imageslim)
`localhost:8500` 访问 `Consul` `dashboard`，同一端口通过不同请求头访问不同API接口，如图：

![image.png](https://cdn.netclub.top/images/e25b1d5e3e04777f241115afcb8da35f.image.webp?imageslim)

Net5 使用Ocelot+Consul

[官网](https://docs.microsoft.com/zh-cn/dotnet/core/install/linux-centos)
```bash
sudo rpm -Uvh https://packages.microsoft.com/config/centos/7/packages-microsoft-prod.rpm
```



安装SDK
```bash
sudo yum install dotnet-sdk-6.0 -y
```
查看是否安装sdk
```bash
dotnet --info
```

![image.png](https://cdn.netclub.top/images/73880eb08ac2c83c3235d26a016fc213.image.webp?imageslim)