AI导航网
微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦！

c# – 使用“一对多”关系和WebApi时的实体框架核心异步/等待死锁

分类：C#作者：编程之家
我在使用EF Core提供程序的异步实现时遇到了死锁.

说我有以下型号：

public class Player
{
    public string PlayerId { get; set;}

    public string Name { get; set;}

    public List<Game> Games { get; set;}
}

public class Game
{
    public string GameId { get; set; }

    public string PlayerId { get; set; }
    public Player Player { get; set;}
}

现在我想运行以下查询：

ctx.Players
.Include(p => p.Games)
.Where(p => p.PlayerId == "123")
.Select(p => new {
    PlayerId = p.PlayerId,Games = p.Games.ToList()
}).ToListAsync();

当我通过Console Application / XUnit测试运行此代码时,它可以作为例外…
但是,当我通过ASP.Net WebApi运行它时,它陷入僵局,永远不会结束……

我一直使用ConfigureAwait(false)来防止这种情况,但似乎有问题的代码在下面.
我认为它可能在EFCore使用的system.interactive.Async库下 – 更具体地说它在：https://github.com/Reactive-Extensions/Rx.NET/blob/develop/Ix.NET/Source/System.Interactive.Async/ToAsyncEnumerable.cs#L72
有一个调用“结果”,它实际上阻止了执行线程.

有没有人遇到过这种行为,也许有一些解决方法？

请注意,如果我没有加载“游戏”实体,那么一切也正常……

编辑：添加StackTrace :(查看对ToEnumerable的调用)

未标记21672 5工作线程grpc 0(cq 0)system.interactive.Async.dll！System.Linq.AsyncEnumerable.ToEnumerable_ normal
mscorlib.dll！System.Threading.Monitor.Wait(object obj,int millisecondsTimeout,bool exitContext)
mscorlib.dll！System.Threading.Monitor.Wait(object obj,int millisecondsTimeout)
mscorlib.dll！System.Threading.ManualResetEventSlim.Wait(int millisecondsTimeout,System.Threading.CancellationToken cancellationToken)
mscorlib.dll！System.Threading.Tasks.Task.SpinThenBlockingWait(int millisecondsTimeout,System.Threading.CancellationToken cancellationToken)
mscorlib.dll！System.Threading.Tasks.Task.InternalWait(int millisecondsTimeout,System.Threading.CancellationToken cancellationToken)
mscorlib.dll！System.Threading.Tasks.Task.GetResultCore(bool waitCompletionNotification)
mscorlib.dll中！System.Threading.Tasks.Task.Result.get()
system.interactive.Async.dll！System.Linq.AsyncEnumerable.ToEnumerable_(System.Collections.Generic.IAsyncEnumerable source)
mscorlib.dll！System.Collections.Generic.List.List(System.Collections.Generic.IEnumerable collection)
System.Core.dll！System.Linq.Enumerable.ToList(System.Collections.Generic.IEnumerable source)
[轻量级功能]
Microsoft.EntityFrameworkCore.dll！Microsoft.EntityFrameworkCore.Query.Internal.AsyncLinqOperatorProvider.SelectAsyncEnumerable.SelectAsyncEnumerator.MoveNext(System.Threading.CancellationToken cancellationToken)
mscorlib.dll！System.Runtime.CompilerServices.AsyncmethodBuilderCore.MoveNextRunner.InvokeMoveNext(object stateMachine)
mscorlib.dll！System.Threading.ExecutionContext.RunInternal(System.Threading.ExecutionContext executionContext,System.Threading.ContextCallback callback,object state,bool preserveSyncCtx)
mscorlib.dll！System.Threading.ExecutionContext.Run(System.Threading.ExecutionContext executionContext,bool preserveSyncCtx)
mscorlib.dll中！System.Runtime.CompilerServices.AsyncmethodBuilderCore.MoveNextRunner.Run()
mscorlib.dll中！System.Runtime.CompilerServices.AsyncmethodBuilderCore.OutputAsyncCausalityEvents.AnonymousMethod__0()
mscorlib.dll中！System.Runtime.CompilerServices.AsyncmethodBuilderCore.ContinuationWrapper.Invoke()
mscorlib.dll中！System.Runtime.CompilerServices.TaskAwaiter.OutputWaitEtwEvents.AnonymousMethod__0()
mscorlib.dll中！System.Runtime.CompilerServices.AsyncmethodBuilderCore.ContinuationWrapper.Invoke()
mscorlib.dll！System.Threading.Tasks.AwaitTaskContinuation.RunorScheduleAction(System.Action action,bool allowInlining,ref System.Threading.Tasks.Task currentTask)
mscorlib.dll中！System.Threading.Tasks.Task.FinishContinuations()
mscorlib.dll中！System.Threading.Tasks.Task.FinishStageThree()
mscorlib.dll！System.Threading.Tasks.Task.TrySetResult(bool result)
mscorlib.dll！System.Runtime.CompilerServices.AsyncTaskMethodBuilder.SetResult(bool result)
NG.Data.Spanner.EF.dll！NG.Data.Spanner.EF.Query.Internal.SpannerAsyncQueryingEnumerable.SpannerAsyncEnumerator.MoveNext(System.Threading.CancellationToken cancellationToken)第55行
[恢复异步方法]
mscorlib.dll！System.Runtime.CompilerServices.AsyncmethodBuilderCore.MoveNextRunner.InvokeMoveNext(object stateMachine)
mscorlib.dll！System.Threading.ExecutionContext.RunInternal(System.Threading.ExecutionContext executionContext,ref System.Threading.Tasks.Task currentTask)
mscorlib.dll中！System.Threading.Tasks.Task.FinishContinuations()
mscorlib.dll中！System.Threading.Tasks.Task.FinishStageThree()
mscorlib.dll！System.Threading.Tasks.Task.TrySetResult(bool result)
mscorlib.dll！System.Runtime.CompilerServices.AsyncTaskMethodBuilder.SetResult(bool result)
Microsoft.EntityFrameworkCore.dll！Microsoft.EntityFrameworkCore.Query.Internal.AsyncLinqOperatorProvider.SelectAsyncEnumerable.SelectAsyncEnumerator.MoveNext(System.Threading.CancellationToken cancellationToken)
mscorlib.dll！System.Runtime.CompilerServices.AsyncmethodBuilderCore.MoveNextRunner.InvokeMoveNext(object stateMachine)
mscorlib.dll！System.Threading.ExecutionContext.RunInternal(System.Threading.ExecutionContext executionContext,ref System.Threading.Tasks.Task currentTask)
mscorlib.dll中！System.Threading.Tasks.Task.FinishContinuations()
mscorlib.dll中！System.Threading.Tasks.Task.FinishStageThree()
mscorlib.dll！System.Threading.Tasks.Task.TrySetResult(bool result)
mscorlib.dll！System.Runtime.CompilerServices.AsyncTaskMethodBuilder.SetResult(bool result)
Microsoft.EntityFrameworkCore.Relational.dll！Microsoft.EntityFrameworkCore.Query.Internal.AsyncQueryingEnumerable.AsyncEnumerator.MoveNext(System.Threading.CancellationToken cancellationToken)
mscorlib.dll！System.Runtime.CompilerServices.AsyncmethodBuilderCore.MoveNextRunner.InvokeMoveNext(object stateMachine)
mscorlib.dll！System.Threading.ExecutionContext.RunInternal(System.Threading.ExecutionContext executionContext,ref System.Threading.Tasks.Task currentTask)
mscorlib.dll中！System.Threading.Tasks.Task.FinishContinuations()
mscorlib.dll中！System.Threading.Tasks.Task.FinishStageThree()
mscorlib.dll！System.Threading.Tasks.Task.TrySetResult(bool result)
mscorlib.dll！System.Runtime.CompilerServices.AsyncTaskMethodBuilder.SetResult(bool result)
Microsoft.EntityFrameworkCore.Relational.dll！Microsoft.EntityFrameworkCore.Query.Internal.AsyncQueryingEnumerable.AsyncEnumerator.BufferlessMoveNext(bool buffer,System.Threading.CancellationToken cancellationToken)
mscorlib.dll！System.Runtime.CompilerServices.AsyncmethodBuilderCore.MoveNextRunner.InvokeMoveNext(object stateMachine)
mscorlib.dll！System.Threading.ExecutionContext.RunInternal(System.Threading.ExecutionContext executionContext,ref System.Threading.Tasks.Task currentTask)
mscorlib.dll中！System.Threading.Tasks.Task.FinishContinuations()
mscorlib.dll中！System.Threading.Tasks.Task.FinishStageThree()
mscorlib.dll！System.Threading.Tasks.Task.TrySetResult(System .__ Canon result)
mscorlib.dll！System.Threading.Tasks.taskcompletionsource.TrySetResult(System .__ Canon result)
Microsoft.EntityFrameworkCore.Relational.dll！System.Threading.Tasks.TaskExtensions.Cast.AnonymousMethod__0(System.Threading.Tasks.Task t)
mscorlib.dll中！System.Threading.Tasks.ContinuationTaskFromresultTask.InnerInvoke()
mscorlib.dll中！System.Threading.Tasks.Task.Execute()
mscorlib.dll！System.Threading.Tasks.Task.ExecutionContextCallback(object obj)
mscorlib.dll！System.Threading.ExecutionContext.RunInternal(System.Threading.ExecutionContext executionContext,bool preserveSyncCtx)
mscorlib.dll！System.Threading.Tasks.Task.ExecuteWithThreadLocal(ref System.Threading.Tasks.Task currentTaskSlot)
mscorlib.dll！System.Threading.Tasks.Task.ExecuteEntry(bool bPreventDoubleExecution)
mscorlib.dll！System.Threading.Tasks.ThreadPoolTask​​Scheduler.TryExecuteTaskInline(System.Threading.Tasks.Task task,bool taskwasprevIoUslyQueued)
mscorlib.dll！System.Threading.Tasks.TaskScheduler.TryRunInline(System.Threading.Tasks.Task task,bool taskwasprevIoUslyQueued)
mscorlib.dll！System.Threading.Tasks.TaskContinuation.InlineIfPossibleOrElseQueue(System.Threading.Tasks.Task任务,bool needsProtection)
mscorlib.dll！System.Threading.Tasks.StandardTaskContinuation.Run(System.Threading.Tasks.Task completedTask,bool bCanInlineContinuationTask)
mscorlib.dll中！System.Threading.Tasks.Task.FinishContinuations()
mscorlib.dll中！System.Threading.Tasks.Task.FinishStageThree()
mscorlib.dll！System.Threading.Tasks.Task.TrySetResult(System .__ Canon result)
mscorlib.dll！System.Runtime.CompilerServices.AsyncTaskMethodBuilder.SetResult(object result)
NG.Data.Spanner.EF.dll！NG.Data.Spanner.EF.Storage.Internal.SpannerRelationalCommand.ExecuteAsync(Microsoft.EntityFrameworkCore.Storage.IRelationalConnection连接,字符串executeMethod,System.Collections.Generic.IReadOnlyDictionary parameterValues,bool closeConnection,System.Threading.CancellationToken cancellationToken)第41行
[恢复异步方法]
mscorlib.dll！System.Runtime.CompilerServices.AsyncmethodBuilderCore.MoveNextRunner.InvokeMoveNext(object stateMachine)
mscorlib.dll！System.Threading.ExecutionContext.RunInternal(System.Threading.ExecutionContext executionContext,ref System.Threading.Tasks.Task currentTask)
mscorlib.dll中！System.Threading.Tasks.Task.FinishContinuations()
mscorlib.dll中！System.Threading.Tasks.Task.FinishStageThree()
mscorlib.dll！System.Threading.Tasks.Task.TrySetResult(System .__ Canon result)
mscorlib.dll！System.Runtime.CompilerServices.AsyncTaskMethodBuilder.SetResult(object result)
NG.Data.Spanner.EF.dll！NG.Data.Spanner.EF.Storage.Internal.SpannerRelationalCommand.ExecuteAsync(NG.Data.Spanner.EF.Storage.Internal.IOBehavior ioBehavior,Microsoft.EntityFrameworkCore.Storage.IRelationalConnection连接,string executeMethod,System.Threading.CancellationToken cancellationToken)第128行
[恢复异步方法]
mscorlib.dll！System.Runtime.CompilerServices.AsyncmethodBuilderCore.MoveNextRunner.InvokeMoveNext(object stateMachine)
mscorlib.dll！System.Threading.ExecutionContext.RunInternal(System.Threading.ExecutionContext executionContext,ref System.Threading.Tasks.Task currentTask)
mscorlib.dll中！System.Threading.Tasks.Task.FinishContinuations()
mscorlib.dll中！System.Threading.Tasks.Task.FinishStageThree()
mscorlib.dll！System.Threading.Tasks.Task.TrySetResult(System .__ Canon result)
mscorlib.dll！System.Runtime.CompilerServices.AsyncTaskMethodBuilder.SetResult(System.Data.Common.DbDataReader result)
NG.Data.Spanner.dll！NG.Data.Spanner.SpannerCommand.ExecuteDbDataReaderAsync(System.Data.CommandBehavior behavior,System.Threading.CancellationToken cancellationToken)第67行
[恢复异步方法]
mscorlib.dll！System.Runtime.CompilerServices.AsyncmethodBuilderCore.MoveNextRunner.InvokeMoveNext(object stateMachine)
mscorlib.dll！System.Threading.ExecutionContext.RunInternal(System.Threading.ExecutionContext executionContext,ref System.Threading.Tasks.Task currentTask)
mscorlib.dll中！System.Threading.Tasks.Task.FinishContinuations()
mscorlib.dll中！System.Threading.Tasks.Task.FinishStageThree()
mscorlib.dll！System.Threading.Tasks.Task.TrySetResult(System .__ Canon result)
mscorlib.dll！System.Runtime.CompilerServices.AsyncTaskMethodBuilder.SetResult(Google.Cloud.Spanner.V1.ResultSet result)
NG.Data.Spanner.dll！NG.Data.Spanner.SpannerConnection.RunQuery(string commandText)第118行
[恢复异步方法]
mscorlib.dll！System.Runtime.CompilerServices.AsyncmethodBuilderCore.MoveNextRunner.InvokeMoveNext(object stateMachine)
mscorlib.dll！System.Threading.ExecutionContext.RunInternal(System.Threading.ExecutionContext executionContext,ref System.Threading.Tasks.Task currentTask)
mscorlib.dll中！System.Threading.Tasks.Task.FinishContinuations()
mscorlib.dll中！System.Threading.Tasks.Task.FinishStageThree()
mscorlib.dll！System.Threading.Tasks.Task.TrySetResult(System .__ Canon result)
mscorlib.dll！System.Runtime.CompilerServices.AsyncTaskMethodBuilder.SetResult(Google.Cloud.Spanner.V1.ResultSet result)
Google.Api.Gax.Grpc.dll！Google.Api.Gax.Grpc.ApiCallRetryExtensions.WithRetry.AnonymousMethod__0(Google.Cloud.Spanner.V1.ExecutesqlRequest request,Google.Api.Gax.Grpc.CallSettings callSettings)
mscorlib.dll！System.Runtime.CompilerServices.AsyncmethodBuilderCore.MoveNextRunner.InvokeMoveNext(object stateMachine)
mscorlib.dll！System.Threading.ExecutionContext.RunInternal(System.Threading.ExecutionContext executionContext,ref System.Threading.Tasks.Task currentTask)
mscorlib.dll中！System.Threading.Tasks.Task.FinishContinuations()
mscorlib.dll中！System.Threading.Tasks.Task.FinishStageThree()
mscorlib.dll！System.Threading.Tasks.Task.TrySetResult(System .__ Canon result)
mscorlib.dll！System.Threading.Tasks.taskcompletionsource.TrySetResult(System .__ Canon result)
mscorlib.dll！System.Threading.Tasks.taskcompletionsource.SetResult(System .__ Canon result)
Grpc.Core.dll！Grpc.Core.Internal.AsyncCall.HandleUnaryResponse(bool成功,Grpc.Core.Internal.ClientSideStatus receivedStatus,byte [] receivedMessage,Grpc.Core.Metadata responseHeaders)
Grpc.Core.dll！Grpc.Core.Internal.CallSafeHandle.StartUnary.AnonymousMethod__0(bool success,Grpc.Core.Internal.BatchContextSafeHandle context)
Grpc.Core.dll！Grpc.Core.Internal.CompletionRegistry.HandleBatchCompletion(bool成功,Grpc.Core.Internal.BatchContextSafeHandle ctx,Grpc.Core.Internal.BatchCompletionDelegate回调)
Grpc.Core.dll！Grpc.Core.Internal.CompletionRegistry.RegisterBatchCompletion.AnonymousMethod__0(bool成功)
Grpc.Core.dll！Grpc.Core.Internal.GrpcThreadPool.RunHandlerLoop(Grpc.Core.Internal.CompletionQueueSafeHandle cq,Grpc.Core.Profiling.IProfiler optionalProfiler)
Grpc.Core.dll！Grpc.Core.Internal.GrpcThreadPool.CreateAndStartThread.AnonymousMethod__0()
mscorlib.dll！System.Threading.ThreadHelper.ThreadStart_Context(对象状态)
mscorlib.dll！System.Threading.ExecutionContext.RunInternal(System.Threading.ExecutionContext executionContext,System.Threading.ContextCallback回调,对象状态)
mscorlib.dll中！System.Threading.ThreadHelper.ThreadStart()

解决方法

经过长时间的调试后,我发现了问题,并做了一些解决它的工作.我会试着解释一下：

我正在为Google Spanner db构建EF Core提供程序.为此,我使用的是Google Spanner DotNet API – 尽管它尚未公开且非常不成熟的API(实际上它只是自动生成的代码).

这个API使用gRPC API,我看到的是在第一次使用此API的异步调用时,gRPC线程(gRPC有自己的线程池实现)被使用并将用于下一次执行调用 – 因为continuation将继续仅从gRPC线程池中的此线程运行.

EFCore为使用system.interactive.Async lib的“Games”列表调用ToEnumerable.在ToEnumerable实现上,它实际上调用“Result”来阻止执行线程并等待结果.因为使用了gRPC线程并等待执行完成所以我们有一个死锁…

我的解决方法是使用以下代码：

GrpcEnvironment.SetCompletionQueueCount(1);

这样,允许continuation在gRPC线程池的其他线程上运行.

这只是一种解决方法,应该使用.然而,在此期间它有助于解决问题……

真正的解决方案应该是在system.interactive.Async lib的EFCore用法中,关于ToEnumerable …(它应该是纯异步).

编辑：
如果它可能与任何人相关：
刚刚发布了针对Google Spanner db的EF Core提供商：
https://github.com/NoGame/NG.Data.Spanner

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 [email protected] 举报，一经查实，本站将立刻删除。

相关推荐

Blazor 调用 Clipboard API 读写剪贴板数据
目录简介使用JS互操作使用ClipLazor库创建项目使用方法简单测试参考链接 简介 Clipboard API 是一种允许网页读取剪贴板数据或向其中写入数据的API，主要有两个方法： navigator.clipboard.writeText() ：用于将文本写...
C# 轻量级 ORM 框架 NPoco 的简单应用
目录简介快速入门安装 NuGet 包实体类User数据库类DbFactory增删改查InsertSelectUpdateDelete总结 简介 NPoco 是 PetaPoco 的一个分支，具有一些额外的功能，截至现在 github 星数 839。NPoco 中文资料没多少，我是...
C#简单配置类及数据绑定
本文实现一个简单的配置类，原理比较简单，适用于一些小型项目。主要实现以下功能：保存配置到json文件、从文件或实例加载配置类的属性值、数据绑定到界面控件。&#xA;一般情况下，项目都会提供配置的设置界面，很...
C#获取Description特性的扩展类
C#中Description特性主要用于枚举和属性，方法比较简单，记录一下以便后期使用。 扩展类DescriptionExtension代码如下： using System; using System.ComponentModel; using System.Reflection; /// &lt;
C#实现软件开机自启动（不需要管理员权限）
[TOC] # 原理简介 本文参考[C#/WPF/WinForm/程序实现软件开机自动启动的两种常用方法](https://blog.csdn.net/weixin_42288432/article/details/120059296)，将里面中的第一种方法做了封装成**AutoStart**类，使
C#爬取动态网页上的信息：B站主页
目录简介获取 HTML 文档解析 HTML 文档测试补充：使用 CSS 选择器参考文章 简介 动态内容网站使用 JavaScript 脚本动态检索和渲染数据，爬取信息时需要模拟浏览器行为，否则获取到的源码基本是空的。 本文使用的爬取...
C#项目管理引用的dll文件
这篇文章主要简单记录一下C#项目的dll文件管理方法，以便后期使用。 设置dll路径 参考C#开发奇技淫巧三：把dll放在不同的目录让你的程序更整洁中间的 方法一：配置App.config文件的privatePath ： &lt;runtime&a...
C# 常用特性(Attribute)
使用特性，可以有效地将元数据或声明性信息与代码（程序集、类型、方法、属性等）相关联。 将特性与程序实体相关联后，可以在运行时使用反射这项技术查询特性。&#xA;在 C# 中，通过用方括号 ([]) 将特性名称括起...
C#事件总线
事件总线是对发布-订阅模式的一种实现，是一种集中式事件处理机制，允许不同的组件之间进行彼此通信而又不需要相互依赖，达到一种解耦的目的。&#xA;EventBus维护一个事件的字典，发布者、订阅者在事件总线中获取...
C#中使用jieba.NET、WordCloudSharp制作词云图
词云”由美国西北大学新闻学副教授、新媒体专业主任里奇·戈登（Rich Gordon）于2006年最先使用，是通过形成“关键词云层”或“关键词渲染”，对文本中出现频率较高的“关键词”的视觉上的突出。词云图过滤掉大量的文...
    pythonJavaScriptjavaHTMLreactjsC#AndroidCSSNode.jssqlrpython-3.xMysqLjQueryc++pandasFlutterangularIOSdjangolinuxswifttypescript路由器JSON路由器设置无线路由器h3c华三华三路由器设置华三路由器电脑软件教程arraysdocker软件图文教程Cvue.jslaravelspring-bootreact-native