- c - 在位数组中找到第一个零
- linux - Unix 显示有关匹配两种模式之一的文件的信息
- 正则表达式替换多个文件
- linux - 隐藏来自 xtrace 的命令
以下 C# 代码:
class Program
{
static readonly List<TaskCompletionSource<bool>> buffer =
new List<TaskCompletionSource<bool>>();
static Timer timer;
public static void Main()
{
var outstanding = Enumerable.Range(1, 10)
.Select(Enqueue)
.ToArray();
timer = new Timer(x => Flush(), null,
TimeSpan.FromSeconds(1),
TimeSpan.FromMilliseconds(-1));
try
{
Task.WaitAll(outstanding);
}
catch {}
Console.ReadKey();
}
static Task Enqueue(int i)
{
var task = new TaskCompletionSource<bool>();
buffer.Add(task);
return task.Task;
}
static void Flush()
{
try
{
throw new ArgumentException("test");
}
catch (Exception e)
{
foreach (var each in buffer)
{
var lenBefore = e.StackTrace.Length;
each.TrySetException(e);
var lenAfter = e.StackTrace.Length;
Console.WriteLine($"Before - After: {lenBefore} - {lenAfter}");
Console.WriteLine(e.StackTrace);
}
}
}
}
产生:
Before - After: 149 - 149
Before - After: 149 - 149
Before - After: 149 - 149
Before - After: 149 - 149
Before - After: 149 - 149
Before - After: 149 - 149
Before - After: 149 - 149
Before - After: 149 - 149
Before - After: 149 - 149
Before - After: 149 - 149
但是当我将 Enqueue
方法更改为异步时:
static async Task Enqueue(int i)
{
var task = new TaskCompletionSource<bool>();
buffer.Add(task);
return await task.Task;
}
结果是:
Before - After: 149 - 643
Before - After: 643 - 1137
Before - After: 1137 - 1631
Before - After: 1631 - 2125
Before - After: 2125 - 2619
Before - After: 2619 - 3113
Before - After: 3113 - 3607
Before - After: 3607 - 4101
Before - After: 4101 - 4595
Before - After: 4595 - 5089
看起来每个缓冲项目的堆栈跟踪递归增长。对于第一项异常堆栈跟踪将是:
at Program.Flush() in C:\src\Program.cs:line 41
--- End of stack trace from previous location where exception was thrown ---
at System.Runtime.CompilerServices.TaskAwaiter.ThrowForNonSuccess(Task task)
at System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotificati...
at System.Runtime.CompilerServices.TaskAwaiter`1.GetResult()
at Program.<Enqueue>d__3.MoveNext() in C:\src\Program.cs:line 34
虽然第二个看起来像下面等等:
at Program.Flush() in C:\src\Program.cs:line 41
--- End of stack trace from previous location where exception was thrown ---
at System.Runtime.CompilerServices.TaskAwaiter.ThrowForNonSuccess(Task task)
at System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotificati...
at System.Runtime.CompilerServices.TaskAwaiter`1.GetResult()
at Program.<Enqueue>d__3.MoveNext() in C:\src\Program.cs:line 34
--- End of stack trace from previous location where exception was thrown ---
at System.Runtime.CompilerServices.TaskAwaiter.ThrowForNonSuccess(Task task)
at System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotificati...
at System.Runtime.CompilerServices.TaskAwaiter`1.GetResult()
at Program.<Enqueue>d__3.MoveNext() in C:\src\Program.cs:line 34
这里发生了什么以及如何解决它?
最佳答案
简答:await
尝试解包结果,而带有 await
的方法不会尝试访问任务结果。
更长的答案:
TaskAwaiter
的方法被内联,HandleNonSuccessAndDebuggerNotification调用 ThrowForNonSuccess这似乎也是内联的,因为单个异常用于设置 10 个 TaskCompletionSource
的结果,the reason of growing stack of that exception can be seen here .简单的解决方案是在每个 TrySetException
调用上使用 new Exception("Some descriptive message", originalException)
。
关于c# - 使用 async/await 和 TaskCompletionSource 的奇怪堆栈跟踪增长,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/46467275/
我试图理解 TaskCompletionSource 的目的以及它与异步/无线程工作的关系。我想我有大致的想法,但我想确保我的理解是正确的。 我首先开始研究任务并行库 (TPL),以确定是否有一种好方
如何创建 TaskCompletionSource对于 Task而不是 Task ? 最佳答案 没有非通用版本。然而, Task 源自 Task , 所以你可以只使用 TaskCompletionSo
如果取消完成源,我会在结果变量中收到什么? async void SomeMethod() { ..... Run(); var result = await GetResult()
我有使用 await 关键字异步调用的函数: public Task RequestStateForEntity(EntityKey entity, string propName) { va
如果我的 TaskCompletionSource 公开的任务可能永远不会被调用,我如何才能推迟结果的计算,除非并且直到有人等待该任务? 例如,我想阻止其他异步执行线程,直到使用以下函数 WaitOn
我有这样一个功能: public async Task DoSomething() { var tcs = new TaskCompletionSource(); // Here is t
我正在编写一个库,其中包含基于 .Net 任务的调度功能(不是标准的 TaskScheduler 、 IScheduler ...)。我正在使用 TaskCompletionSource , 和 Ta
假设我有一些无法更改的系统“BlackBox”,并且我想尝试用它做一些工作 2 秒钟,如果它无法完成 - 停止并继续其他应用程序: let log msg = let timestamp =
TaskCompletionSource 会发生什么?及其Task如果TaskCompletionSource永远不会完成(即 SetCancelled 、 SetException 或 SetRes
我想要一个 EventWaitHandle -like Task,我在一端等待它,然后将其设置为在另一端完成。 TaskCompletionSource几乎是我想要的,但它需要我传递一个值。我可以只使
我目前正在实现一个依赖 TCP/IP 进行传输(持久连接)的应用程序协议(protocol)库。 我正在尝试使用 C#5 async/await 构造依赖于 TAP 模式来实现一个不错的异步实现,主要
我的 View 模型调用服务中的一个方法来获取图像。图像是从外部库(Xamarin 中的 iOS API)获取的,它使用回调机制而不是等待。 为了使我的方法可等待,我将该方法包装在 TaskCompl
使用 TaskCompletionSource.SetResult() 将在一个线程上创建的非线程安全对象传递给另一个线程是否安全? 例如在这个人为的例子中: using System; using
我正在尝试创建一个异步 ProducerConsumerCollection,为此,我正在使用此 msdn 页面(http://msdn.microsoft.com/en-us/library/hh8
拥有found this way关于使用 await 调用带有回调的异步方法,我在 Argotic RSS 阅读器库中使用了它: var tcs = new TaskCompletionSource(
如何判断 TaskCompletionSource.TrySetResult 发起的延续是同步执行还是异步执行? 例如: // class A void RegisterNotification(Ta
考虑以下代码: public Task SomeAsyncMethod() { var tcs = new TaskCompletionSource(); ... do somethi
我正在将一些异步/等待代码转换为链式任务,因此我可以在已发布的框架中使用它。等待代码如下所示 public async Task Get() { var message = await Invok
我有一个黑盒对象,它公开了一个方法来启动异步操作,并在操作完成时触发一个事件。我把它包装成 Task BlackBoxOperationAysnc()使用 TaskCompletionSource 的
我发现 TaskCompletionSource.SetResult(); 在返回之前调用等待任务的代码。就我而言,这会导致死锁。 这是在普通Thread中启动的简化版本 void ReceiverR
我是一名优秀的程序员,十分优秀!