channel 相关问题

一种通信结构，支持在执行线程之间发送对象。您可以并且应该使用此标记来引用通用编程概念或各种语言或库中的特定实现。在后一种情况下，不要忘记添加适当的标签。

我正在读《Go in action》这本书。这是对无缓冲通道的描述：无缓冲通道是没有能力保存任何值的通道在收到之前。这些类型的茶...

go channel

回答 4 投票 0

我有一个长期运行的类（不是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

Django 通道重新加载或刷新 self.scope['session'] 值

我有多个消费者，并且想使用 self.scope['sessions'] 将值从一个消费者传递到另一个消费者。它们是同时创建和初始化的。设置并保存后（...

django session scope consumer channel

回答 1 投票 0

解释缓冲和非缓冲Go通道之间的区别

考虑以下 Go 代码：包主导入“fmt” 函数主() { buf := make(chan 字符串, 1) 缓冲<- "Hello, 世界" fmt.Println(<-buf) nonbuf := make...

go channel goroutine

回答 1 投票 0

Go：用于通用数据处理的接口{}的chan

我目前正在尝试用golang编写一些生产者和消费者代码，试图保持它的通用性。它看起来像这样。函数生产者 () { 共享数据通道 <- getData() //retu...