windows-services 相关问题

我有一个长期运行的类（不是BackgroundService），它有一个内部通道，我用它来缓冲传入的请求。存在Enqueue方法，如下：公共异步任务我有一个长时间运行的类（不是BackgroundService），它有一个内部通道，我用它来缓冲传入的请求。存在一个Enqueue方法，如下： public async Task<bool> Enqueue(IMessage message) { bool result; try { if (_cts.IsCancellationRequested) { _logger.LogInformation("{TypeName} cannot be enqueued because the queue is stopped.", message.GetType().Name); result = false; } else { await _messageChannel.Writer.WriteAsync(message); result = true; _logger.LogInformation("Message {TypeName} written to internal channel.", message.GetType().Name); } } catch (ChannelClosedException) { _logger.LogInformation("{TypeName} cannot be enqueued because the channel is closed.", message.GetType().Name); result = false; } catch (Exception e) { _logger.LogError(e, "Error enqueuing {TypeName}", message.GetType().Name); result = false; } return result; } 在类构造函数中，使用以下命令启动消息读取器循环： Task.Run(() => _MainMessageLoop(_cts.Token)); _MainMessageLoop 看起来像： private async Task _MainMessageLoop(CancellationToken stoppingToken) { try { var channelReader = _messageChannel.Reader; while (await channelReader.WaitToReadAsync(stoppingToken).ConfigureAwait(false)) { try { var item = await channelReader.ReadAsync(stoppingToken).ConfigureAwait(false); _logger.LogInformation("Message {TypeName} read from internal channel.", item.GetType().Name); await _DoSomethingAsync(item); } catch (Exception e) { _logger.LogError(e, "Error doing something"); } } _logger.LogInformation("Channel reader loop exited {MethodName}.", nameof(_MainMessageLoop)); } catch (OperationCanceledException) { _logger.LogDebug("OperationCanceled {MethodName}", nameof(_MainMessageLoop)); throw; } catch (Exception e) { _logger.LogError(e, "Error in {MethodName}", nameof(_MainMessageLoop)); throw; } } 这在一段时间内效果很好（几个小时，消息负载非常轻），然后就停止了。根据日志，写入仍在发生，但读取端卡住了。没有与读取失败、抛出异常等相关的日志消息。读取循环似乎停止了。我尝试了有界/无界、TryRead与ReadAsync的几种组合，每种组合的结果大致相同。写入仍在发生（这意味着该对象还活着并且运行良好），没有任何运气。大多数文档似乎都没有暗示这一点，但我认为我正在做一些不符合预期的事情，或者某个地方存在错误。我在应用程序中使用的其他通道工作正常，但它们是 HostedService 级别的单例。有人遇到过类似的事情吗？我的猜测如下，GC 清理了你的Task。在 _MainMessageLoop 内部初始等待之后，执行将返回到 Task.Run，这样 Task 就“结束”了，因为之后没有执行任何操作。如果没有人持有对从 Task 创建的 Task.Run 的引用，它最终将被 GC 清理。将 Task 存储为属性或字段，然后重试。在构造函数内部启动 Task 的想法是一个坏主意，特别是如果 Task 未存储在类内部，因为它可能会导致 UnobservedTaskException。

c# .net-core windows-services channel

回答 1 投票 0

windows-services 相关问题

最新问题