我正在尝试使用 FtpWebRequest
异步调用(BeginGetResponse
/EndGetResponse
)。
但是,BeginGetResponse
的回调似乎与我的应用程序在同一个线程中运行,而我的印象是它会使用不同的(和线程池)线程。这意味着我的应用程序在继续之前会在回调中阻塞。
我已经设置了一个 LINQPad 概念验证,如下所示:
"Starting".Dump();
Thread.CurrentThread.GetHashCode().Dump();
Thread.CurrentThread.IsThreadPoolThread.Dump();
IAsyncResult result = request.BeginGetResponse((ar) =>
{
"Inside Callback".Dump();
Thread.CurrentThread.GetHashCode().Dump();
Thread.CurrentThread.IsThreadPoolThread.Dump();
var resp = request.EndGetResponse(ar);
"Callback Complete".Dump();
}, null);
"After Callback".Dump();
打印输出如下:
Starting
33
False
Inside Callback
33
False
Callback Complete
After Callback
我期望的是这样的(假设回调运行时间足够长):
Starting
33
False
Inside Callback
44
True
After Callback // App continues despite callback running
Callback Complete
如果回调在同一个应用程序线程上运行,这意味着如果回调中的某些内容需要很长时间(例如,为了参数引入 Thread.Sleep
),我的应用程序会阻塞在那里。这意味着我无法为请求设置超时(例如使用 ThreadPool.RegisterWaitForSingleObject
)。
我是不是漏掉了什么?
最佳答案
当 BeginXXX 方法可以立即完成异步操作时,它不会在线程池线程上运行回调,而是设置 IAsyncResult.CompletedSynchronously Property为 true
并同步执行回调。
关于c# - 为什么我的异步回调在同一个线程中运行?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/11287048/