- VisualStudio2022插件的安装及使用-编程手把手系列文章
- pprof-在现网场景怎么用
- C#实现的下拉多选框,下拉多选树,多级节点
- 【学习笔记】基础数据结构:猫树
在上一篇通信协议碰到了多线程,阻塞、非阻塞、锁、信号量...,会碰到很多问题。因此我感觉很有必要研究多线程与异步编程.
我说明一下这个例子。 这是一个演示异步编程的例子.
Main
方法中,以一发即忘
的方式调用异步方法StartJob()
。PrintCurrentTime()
输出时间。一发即忘
的方式调用异步方法时,在异步方法中碰到阻塞时,主线程返回同步方法中继续执行。而异步方法在另一个线程中继续执行。internal class Program
{
static void Main(string[] args)
{
while (true)
{
Console.WriteLine($"(Thread ID: {Thread.CurrentThread.ManagedThreadId}) Enter 'time' to get current time or 'job [name]' to start a job:");
string input = Console.ReadLine();
if (input.StartsWith("time"))
{
// 输出当前时间
PrintCurrentTime();
}
else if (input.StartsWith("job"))
{
// 启动一个异步任务,执行指定的工作
string[] parts = input.Split(new char[] { ' ' }, 2);
string jobName = parts.Length > 1 ? parts[1] : string.Empty;
StartJob(jobName);
}
else
{
Console.WriteLine("Invalid input. Please try again.");
}
}
}
static void PrintCurrentTime()
{
Console.WriteLine($"(Thread ID: {Thread.CurrentThread.ManagedThreadId}) Current time: {DateTime.Now}");
}
static async void StartJob(string jobName)
{
// 获取主线程的线程 ID
int mainThreadId = Thread.CurrentThread.ManagedThreadId;
// 检查是否在主线程上
bool onMainThread = Thread.CurrentThread.ManagedThreadId == mainThreadId;
Console.WriteLine($"(Thread ID: {Thread.CurrentThread.ManagedThreadId}) Starting job '{jobName}'. This will take 10 seconds...");
// 输出主线程上下文移动情况
Console.WriteLine($"(Thread ID: {Thread.CurrentThread.ManagedThreadId}) Main thread context moved to new thread: {(!onMainThread)}");
await Task.Delay(10000); // 模拟任务需要10秒钟完成
// 输出任务完成信息及上下文移动情况
Console.WriteLine($"(Thread ID: {Thread.CurrentThread.ManagedThreadId}) Job '{jobName}' completed. Main thread context moved to new thread: {(!onMainThread)}");
}
}
一个方法从一个线程代码栈被切换,或者说被剪切到另一个线程代码栈上去,可以称为上下文流转。 这对于理解异步编程是一个重要的点。 但由于上面的程序缺少必要变量,我需要在不同位置加几个变量,来展示上下文确实被移动了.
static async void StartJob(string jobName)
{
int mainThreadId = Thread.CurrentThread.ManagedThreadId;
// 检查是否在主线程上
bool onMainThread = Thread.CurrentThread.ManagedThreadId == mainThreadId;
...
}
可以看到onMainThread一直为False,这个变量从线程1移动到线程5。 而且bool是值类型,在栈上面,这说明StartJob这段代码确实移动到线程5的栈上面去了。(每个线程都有一个调用栈) 。
想要再进一步,更清晰的话说明上下文流转的话,那就得监视这两个线程栈的内容了。万幸的是 vs提供了这个功能,调试 > 窗口 > 并行堆栈.
命中断点时,StartJob方法在主线程24876上 。
10秒后再次命中,StartJob方法跑到了任务线程上。而主线程现在在Main函数的Console.ReadLine()那里阻塞 。
代码阻塞与线程阻塞 在上面的例子中我们引出两种现象,代码阻塞与线程阻塞。 代码阻塞时,线程不一定阻塞,原线程没有阻塞,去执行别的代码了,而由新线程接手当前上下文和调用栈阻塞在这里,比如这里的await Task.Delay(10000)。 代码阻塞时线程也可能阻塞,比如lock(lockObj)和Console.ReadLine()。 为了方便,我们姑且这样命名吧 。
为什么有两个箭头 这里为什么有线程24666和27548两个NET TP Worker(.NET Thread Pool (TP) Worker)?据chatGPT解释,Delay语句在线程池中找了一个线程去执行,一旦延迟时间到达,StartJob会在其中一个线程池线程上恢复执行。计时是一个线程,恢复上下文是另一个线程。Delay就代表了我们的那个耗时线程(不是异步方法所在线程)。 既然有两个线程的联动,其中就出现了一些熟悉的东西。信号量Semaphore,一次性信号量的消耗TrySetResult,但详细过程我还不清楚。 MSDN上的例子也是这样 。
原来把异步方法的上下文移动到新线程N,保证主线程不阻塞(脱离主线程U)。然后N用第三个线程C执行耗时任务,最后把C结果给位于N中的上下文。 站在代码编写者的角度,不特意去看线程的话,就不会注意到异步方法的上下文从一个线程跑到另一个线程上去了。这就是所谓的以同步的方式进行异步编程。 那么线程N的执行就明晰了。先保存上下文,然后启用新线程C进行耗时任务,并阻塞。等C使用信号量或其他什么通知N时,N再根据C的结果继续执行。 可以这样总结 。
async
和await
是一个语法糖。我列出几种可能的异步的实现 。
async
语法糖的实现方式StartJob
将会被编译成一个同步方法StartJobAsync
和一个状态机StartJobAsyncMachine
。internal class Program
{
...
internal static void StartJobAsync(string jobName)
{
StartJobAsyncMachine stateMachine = new StartJobAsyncMachine();
stateMachine.builder = AsyncVoidMethodBuilder.Create();
stateMachine.jobName = jobName;
stateMachine.state = -1;
stateMachine.builder.Start(ref stateMachine);
}
public sealed class StartJobAsyncMachine : IAsyncStateMachine
{
public int state;
public AsyncVoidMethodBuilder builder;
private TaskAwaiter taskAwaiter;
//形参会编译成public字段
public string jobName;
//被新线程使用的局部变量会编译成private字段
private bool onMainThread;
private void MoveNext()
{
int num = state;
try
{
TaskAwaiter awaiter;
if (num != 0)
{
// 获取主线程的线程 ID
int mainThreadId = Thread.CurrentThread.ManagedThreadId;
// 检查是否在主线程上
onMainThread = Thread.CurrentThread.ManagedThreadId == mainThreadId;
Console.WriteLine($"(Thread ID: {Thread.CurrentThread.ManagedThreadId}) Starting job '{jobName}'. This will take 10 seconds...");
// 输出主线程上下文移动情况
Console.WriteLine($"(Thread ID: {Thread.CurrentThread.ManagedThreadId}) Main thread context moved to new thread: {(!onMainThread)}");
awaiter = Task.Delay(10000).GetAwaiter();
if (!awaiter.IsCompleted)
{
num = (state = 0);
taskAwaiter = awaiter;
StartJobAsyncMachine stateMachine = this;
builder.AwaitUnsafeOnCompleted(ref awaiter, ref stateMachine);
return;
}
}
else
{
awaiter = taskAwaiter;
taskAwaiter = default(TaskAwaiter);
num = (state = -1);
}
awaiter.GetResult();
// 输出任务完成信息及上下文移动情况
Console.WriteLine($"(Thread ID: {Thread.CurrentThread.ManagedThreadId}) Job '{jobName}' completed. Main thread context moved to new thread: {(!onMainThread)}");
}
catch (Exception exception)
{
state = -2;
builder.SetException(exception);
return;
}
state = -2;
builder.SetResult();
}
void IAsyncStateMachine.MoveNext()
{
this.MoveNext();
}
private void SetStateMachine(IAsyncStateMachine stateMachine)
{
}
void IAsyncStateMachine.SetStateMachine(IAsyncStateMachine stateMachine)
{
this.SetStateMachine(stateMachine);
}
}
}
StartJobAsync的调用和原方法等效。我在Main中在加一种指令jobMachine调用StartJobAsync。原来的改为job空格 。
else if (input.StartsWith("jobMachine "))
{
// 启动一个异步任务,执行指定的工作
string[] parts = input.Split(new char[] { ' ' }, 2);
string jobName = parts.Length > 1 ? parts[1] : string.Empty;
StartJobAsync(jobName);
}
这种方法到底叫协程还是异步迭代器,我不太分得清,但目的是能够达到的,我暂且就叫做协程好了。 虽然这种做法就像脱裤子放屁,因为协程最后也会编译成状态机。这个例子主要是为了演示直观。 理论上,C#中的异步/等待(async/await)语法并不是直接编译成协程的,而是由编译器生成状态机(state machine)来管理异步操作。但是,我们可以通过理解协程的工作原理以及C#异步/等待模型的特性,来描绘一种可能的编译结果。 这里我写了一个基于协程的异步的实现。效果和原来的等同.
async
方法生成一个协程。而且在异步方法嵌套时,那么async
方法内部的async
方法在编译时就不需要开一个新线程了。要不然得多少线程。internal class Program
{
static void Main(string[] args)
{
while (true)
{
...
else if (input.StartsWith("jobCorotine "))
{
// 启动一个异步任务,执行指定的工作
string[] parts = input.Split(new char[] { ' ' }, 2);
string jobName = parts.Length > 1 ? parts[1] : string.Empty;
StartJobAsync_2(jobName);
}
...
}
}
#region 异步协程
static void StartJobAsync_2(string jobName)
{
StartJobAsyncCorotine startJobCorotine = new StartJobAsyncCorotine();
startJobCorotine.jobName = jobName;
var enumerator = startJobCorotine.DelayedOperations();
var iterator = enumerator.GetEnumerator();
bool next = false;
while (true)
{
next = iterator.MoveNext();
if (!iterator.Current.IsCompleted)
{
//异步方法中存在耗时任务,切换到新线程
break;
}
next = false;
}
if (next == false)
{
return;
}
//异步方法存在耗时任务,切换上下文到新线程
Task.Run(() =>
{
do
{
if (!iterator.Current.IsCompleted)
{
//创建耗时任务线程进行耗时任务
Task.Run(() =>
{
iterator.Current.GetResult();
}).Wait();
}
}
while (iterator.MoveNext());
});
}
public sealed class StartJobAsyncCorotine
{
//形参因为需要运行时赋值,只能写成字段的形式
public string jobName;
public int Count = 1;
public IEnumerable<TaskAwaiter> DelayedOperations()
{
TaskAwaiter awaiter1;
// 获取主线程的线程 ID
int mainThreadId = Thread.CurrentThread.ManagedThreadId;
// 检查是否在主线程上
bool onMainThread = Thread.CurrentThread.ManagedThreadId == mainThreadId;
Console.WriteLine($"(Thread ID: {Thread.CurrentThread.ManagedThreadId}) Starting job '{jobName}'. This will take 10 seconds...");
// 输出主线程上下文移动情况
Console.WriteLine($"(Thread ID: {Thread.CurrentThread.ManagedThreadId}) Main thread context moved to new thread: {(!onMainThread)}");
awaiter1 = Task.Delay(10000).GetAwaiter(); // 模拟任务需要10秒钟完成
//出去判断这是否是耗时任务以切换线程
yield return awaiter1;
// 输出任务完成信息及上下文移动情况
Console.WriteLine($"(Thread ID: {Thread.CurrentThread.ManagedThreadId}) Job '{jobName}' completed. Main thread context moved to new thread: {(!onMainThread)}");
}
}
#endregion
}
这真不需要多说,通过闭包进行捕获上下文真的是太常见了,Ajax中用到吐🤮 。
StartJob是没有返回值的,假如我们需要一个返回值呢,比如一个bool,用于判断接下来的执行流程。 调用异步方法StartJob的同步方法Main之间存在着绝对的分界线——两个线程。同步方法不会被交给异步方法中的那个新线程,没法在同步方法中以同步的方式进行异步编程。 唯一的一点看头是,至少Task还给我们留下了一个回调ContinueWith可用。但条件允许的话,何不把回调的内容写在异步方法内部呢?
最后此篇关于C#异步编程是怎么回事(番外)的文章就讲到这里了,如果你想了解更多关于C#异步编程是怎么回事(番外)的内容请搜索CFSDN的文章或继续浏览相关文章,希望大家以后支持我的博客! 。
我正在尝试打印 timeval 类型的值。实际上我可以打印它,但我收到以下警告: 该行有多个标记 格式“%ld”需要“long int”类型,但参数 2 的类型为“struct timeval” 程序
我正在编写自己的 unix 终端,但在执行命令时遇到问题: 首先,我获取用户输入并将其存储到缓冲区中,然后我将单词分开并将它们存储到我的 argv[] 数组中。IE命令是“firefox”以启动存储在
我是 CUDA 的新手。我有一个关于一个简单程序的问题,希望有人能注意到我的错误。 __global__ void ADD(float* A, float* B, float* C) { con
我有一个关于 C 语言 CGI 编程的一般性问题。 我使用嵌入式 Web 服务器来处理 Web 界面。为此,我在服务器中存储了一个 HTML 文件。在此 HTML 文件中包含 JavaScript 和
**摘要:**在代码的世界中,是存在很多艺术般的写法,这可能也是部分程序员追求编程这项事业的内在动力。 本文分享自华为云社区《【云驻共创】用4种代码中的艺术试图唤回你对编程的兴趣》,作者: break
我有一个函数,它的任务是在父对象中创建一个变量。我想要的是让函数在调用它的级别创建变量。 createVariable testFunc() [1] "test" > testFunc2() [1]
以下代码用于将多个连续的空格替换为1个空格。虽然我设法做到了,但我对花括号的使用感到困惑。 这个实际上运行良好: #include #include int main() { int ch, la
我正在尝试将文件写入磁盘,然后自动重新编译。不幸的是,某事似乎不起作用,我收到一条我还不明白的错误消息(我是 C 初学者 :-)。如果我手动编译生成的 hello.c,一切正常吗?! #include
如何将指针值传递给结构数组; 例如,在 txt 上我有这个: John Doe;xxxx@hotmail.com;214425532; 我的代码: typedef struct Person{
我尝试编写一些代码来检索 objectID,结果是 2B-06-01-04-01-82-31-01-03-01-01 . 这个值不正确吗? // Send a SysObjectId SNMP req
您好,提前感谢您的帮助, (请注意评论部分以获得更多见解:即,以下示例中的成本列已添加到此问题中;西蒙提供了一个很好的答案,但成本列本身并未出现在他的数据响应中,尽管他提供的功能与成本列一起使用) 我
我想知道是否有人能够提出一些解决非线性优化问题的软件包的方法,而非线性优化问题可以为优化解决方案提供整数变量?问题是使具有相等约束的函数最小化,该函数受某些上下边界约束的约束。 我已经在R中使用了'n
我是 R 编程的初学者,正在尝试向具有 50 列的矩阵添加一个额外的列。这个新列将是该行中前 10 个值的平均值。 randomMatrix <- generateMatrix(1,5000,100,
我在《K&R II C 编程 ANSI C》一书中读到,“>>”和“0; nwords--) sum += *buf++; sum = (sum >>
当下拉列表的选择发生变化时,我想: 1) 通过 div 在整个网站上显示一些 GUI 阻止覆盖 2)然后处理一些代码 3) 然后隐藏叠加层。 问题是,当我在事件监听器函数中编写此逻辑时,将执行 onC
我正在使用 Clojure 和 RESTEasy 设计 JAX-RS REST 服务器. 据我了解,用 Lisp 系列语言编写的应用程序比用“传统”命令式语言编写的应用程序更多地构建为“特定于领域的语
我目前正在研究一种替代出勤监控系统作为一项举措。目前,我设计的用户表单如下所示: Time Stamp Userform 它的工作原理如下: 员工将选择他/她将使用的时间戳类型:开始时间、超时、第一次
我是一名学生,试图自学编程,从在线资源和像您这样的人那里获得帮助。我在网上找到了一个练习来创建一个小程序来执行此操作: 编写一个程序,读取数字 a 和 b(长整型)并列出 a 和 b 之间有多少个数字
我正在尝试编写一个 shell 程序,给定一个参数,打印程序的名称和参数中的每个奇数词(即,不是偶数词)。但是,我没有得到预期的结果。在跟踪我的程序时,我注意到,尽管奇数词(例如,第 5 个词,5 %
只是想知道是否有任何 Java API 可以让您控制台式机/笔记本电脑外壳上的 LED? 或者,如果不可能,是否有可能? 最佳答案 如果你说的是前面的 LED 指示电源状态和 HDD 繁忙状态,恐怕没
我是一名优秀的程序员,十分优秀!