我怎么能强制等待继续在同一个线程？
await不保证在生成任务的同一任务上继续：
private void TestButton_Click(object sender, RoutedEventArgs e) { Task.Run(async () => { Debug.WriteLine("running on task " + Task.CurrentId); await Task.Delay(TimeSpan.FromMilliseconds(100)); Debug.WriteLine("running on task " + Task.CurrentId); }); }
这个输出是：
running on task 1 running on task
所以我们可以看到，不仅执行已经移动到另一个任务，而且还移动到UI线程。 如何创建专用任务，并强制等待始终继续执行此任务？ 长时间运行的任务也不会这样做。
我已经看过几个SynchronizationContext实现 ，但到目前为止它们都没有工作，在这种情况下因为它使用线程而System.Threading.Thread不适用于uwp。
所以我们可以看到，不仅执行已经移动到另一个任务，而且还移动到UI线程。
不，它不在UI线程上。 从技术上讲，这也不是一项任务。 我在async方法的Task.CurrentId博客文章中解释了为什么会发生这种情况。
如何创建专用任务，并强制等待始终继续执行此任务？ 长时间运行的任务也不会这样做。
你走在正确的轨道上：你需要一个自定义的SynchronizationContext （或一个自定义的TaskScheduler ）。
我已经看过几个SynchronizationContext实现，但到目前为止它们都没有工作，在这种情况下因为它使用线程而System.Threading.Thread不适用于uwp。
试试我的 。 它应该适用于UWP 10.0。
不要使用Task.Run ，只需使事件处理程序异步
private async void TestButton_Click(object sender, RoutedEventArgs e) { await dedicated(); } private async Task dedicated() { Console.WriteLine("running on task {0}", Task.CurrentId.HasValue ? Task.CurrentId.ToString() : "null"); await Task.Delay(TimeSpan.FromMilliseconds(100)); Console.WriteLine("running on task {0}", Task.CurrentId.HasValue ? Task.CurrentId.ToString() : "null"); }
在此处阅读有关Async方法中的Task.CurrentId更多信息：
所以
Task.CurrentId返回null因为没有任务实际执行。
回复评论
- “ 它仍然在UI线程上运行，而不是生成的任务。 ”
具有线程池线程的情况包含在链接中。 特别要看这个例子
static void Main(string[] args) { var task = Task.Run(() => MainAsync()); task.Wait(); taskRun = task.Id.ToString(); Console.WriteLine(beforeYield + "," + afterYield + "," + taskRun); Console.ReadKey(); } static async Task MainAsync() { beforeYield = Task.CurrentId.HasValue ? Task.CurrentId.ToString() : "null"; await Task.Yield(); afterYield = Task.CurrentId.HasValue ? Task.CurrentId.ToString() : "null"; }
再一次，澄清是
null发挥作用，因为async方法首先作为线程池上的实际任务执行。 但是，在await，它将恢复为线程池上的常规委托（ 而不是实际任务 ）。
- “ 我的问题是如何阻止它这样做 ”
这是async调用的实现细节，我只能再次引用该链接：
这种行为可能只是最简单，最有效的实施的结果。
因此，就真正的 async调用而言，你不能也不应该阻止它这样做。
您所描述的预期行为相当于没有 await的Task.Run
private void expected() { Task task = Task.Run(() => { Console.WriteLine("Before - running on task {0} {1}", Task.CurrentId.HasValue ? Task.CurrentId.ToString() : "null", Environment.CurrentManagedThreadId); Task.Delay(TimeSpan.FromMilliseconds(100)).Wait(); Console.WriteLine("After - running on task {0} {1}", Task.CurrentId.HasValue ? Task.CurrentId.ToString() : "null", Environment.CurrentManagedThreadId); }); }
或嵌套的Task.Run
private void expected() { Task task = Task.Run(() => { Console.WriteLine("Before - running on task {0} {1}", Task.CurrentId.HasValue ? Task.CurrentId.ToString() : "null", Environment.CurrentManagedThreadId); var inner = Task.Run( async () => await Task.Delay(TimeSpan.FromMilliseconds(100))); inner.Wait(); Console.WriteLine("After - running on task {0} {1}", Task.CurrentId.HasValue ? Task.CurrentId.ToString() : "null", Environment.CurrentManagedThreadId); }); }
产量
Before - running on task 312 11 After - running on task 312 11 Before - running on task 360 11 After - running on task 360 11 Before - running on task 403 15 After - running on task 403 15