gpt4 book ai didi

c# - 在新的Thread()中等待是否毫无意义?

转载 作者:行者123 更新时间:2023-12-03 13:15:56 26 4
gpt4 key购买 nike

样例代码:

    class Program
{
static void sleepFunc()
{
int before = Thread.CurrentThread.ManagedThreadId;
Thread.Sleep(5000);
int after = Thread.CurrentThread.ManagedThreadId;
Console.WriteLine($"{before} -> sleep -> {after}");
}

static async void delayFunc()
{
int before = Thread.CurrentThread.ManagedThreadId;
await Task.Delay(5000);
int after = Thread.CurrentThread.ManagedThreadId;
Console.WriteLine($"{before} -> delay -> {after}");
}
static void Main(string[] args)
{
List<Thread> threads = new List<Thread>();
for(int i = 0; i < 10; i++)
{
var thread = new Thread(sleepFunc);
thread.Start();
threads.Add(thread);
}
Thread.Sleep(1000); // just to separate the result sections
for (int i = 0; i < 10; i++)
{
var thread = new Thread(delayFunc);
thread.Start();
threads.Add(thread);
}
Console.ReadLine();
}
}
样本输出:
3 -> sleep -> 3
7 -> sleep -> 7
4 -> sleep -> 4
5 -> sleep -> 5
6 -> sleep -> 6
8 -> sleep -> 8
9 -> sleep -> 9
10 -> sleep -> 10
11 -> sleep -> 11
12 -> sleep -> 12
21 -> delay -> 25
18 -> delay -> 37
15 -> delay -> 36
16 -> delay -> 32
19 -> delay -> 24
20 -> delay -> 27
13 -> delay -> 32
17 -> delay -> 27
22 -> delay -> 25
14 -> delay -> 26
Thread.Sleep()的延续在同一显式创建的线程上运行,而Task.Delay()的延续在不同的(线程池)线程上运行。
由于延续总是在线程池上运行,因此如果函数内有任何等待,使用新的Thread(func)只是毫无意义/浪费/反模式吗?有什么方法可以强制任务在原始的非线程池新线程上继续执行?
我问是因为我读过有人建议在线程中而不是在Task中放置长时间运行的循环(例如,用于套接字通信),但是似乎如果他们调用ReadAsync,那么它最终将成为线程池上的Task无论如何,新的线程毫无意义吗?

最佳答案

Since the continuation always runs on the thread pool, is it just pointless/wasteful/antipattern to use a new Thread(func) if there is an await anywhere inside the func?


永不说永不。但是总的来说,是的,这是没有意义的。

Is there any way to force a task to continue on the original non-thread-pool new thread?


是的,有办法。创建您自己的同步上下文并在该线程中运行该上下文。然后,任何 await都会在该上下文中继续(当然,默认情况下……如果您调用 ConfigureAwait(false),则不允许这样做)。
创建自己的同步上下文相对很少(应该)。您是在自然有其自身的上下文中运行代码,还是在您实际上不在乎哪个线程处理代码的情况下。
显式线程和 async/ await并不是很好地结合在一起。 await语句是一种以线性,同步同步方式组成异步代码的方法。通常,如果创建了显式线程,那是因为您打算在该线程中执行所有工作。在这种情况下甚至没有理由调用异步方法。
相反,如果您使用的是异步方法,那么根据定义,这些方法将以与您使用的任何线程无关的方式异步执行。许多异步操作甚至根本不使用线程!如果您在逻辑中使用 await,那么根据定义,您的代码会短暂运行一段时间,然后在等待异步完成的过程中被暂停。在这种情况下,没有理由使用显式线程。当您不等待其他时间时,线程池是在短暂的时间间隔内执行自己的代码的理想方法。

I'm asking because I read someone recommending to put a long running loop (for socket communication for example) in a Thread instead of in a Task, but it seems that if they call ReadAsync then it ends up being a Task on the thread pool anyway, and the new Thread was pointless?


I/O是使用 await是一种理想技术的经典示例。套接字(从CPU的角度来看)需要很长的时间来等待某件事的发生,而被非常短的时间段打断,以便处理显示的任何数据。通常情况下,将整个线程专用于从套接字读取是个坏主意。在.NET之前很久,仍然存在一个异步I/O模型,该模型允许线程池处理这些间歇性完成的I/O操作。请参见“I/O完成端口”。实际上,.NET套接字API是在该API之上构建的。
如果一个连接很少,则可以摆脱“每个连接一个线程”的模型,但是扩展性很差。使用BSD套接字API中的“选择”模型的较旧替代方案效果更好,但效率很低。使用IOCP,Windows可以有效地管理处理大量套接字的几个线程,而不必将太多的CPU时间专用于I/O,也不必占用太多的线程(每个线程在Windows上使用相对大量的资源)。
显式线程不仅在您描述的场景中毫无意义,而且还有其他非常好的理由无论如何都不这样做。

有用的附加阅读:
What is the difference between task and thread?
Task vs Thread differences

关于c# - 在新的Thread()中等待是否毫无意义?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/64603106/

26 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com