基于 ConcurrentQueue 如何实现异步等待消息?

如果要为ConcurrentQueue 提供一个 async Task<Message> GetMessageAsync 等待某个消息的方法应该怎样做?

我大概查找到的资料是可以用 Task ContinueWith 来实现这个事情。但是调用 async GetMessage 的那个线程会不会被阻塞呢?

查看回复