attdona
2020-12-08 01:57:58
在此示例中，使用@sync和没有错@async。
循环for id in jobs永远不会返回，因为它会永远阻止无休止地等待不再插入Channel的值。
直接从文档：
返回的Channel可以用作for循环中的可迭代对象，在这种情况下，循环变量采用所有产生的>值。通道关闭时，循环终止。
一种解决方案是用一个特殊Int值来表示值流的末尾，例如，-1或者用一个nothing值不可能，则声明jobs为Channel{Union{Int, Nothing}}。
function main()
nodes = Dict( i => false for i in 1:10 )
jobs = Channel{Int}(15)
for i in 1:10
put!(jobs, i)
end
put!(jobs, -1)
@sync for id in jobs
if id == -1
close(jobs)
else
@async process_node(nodes, id)
end
end
println("done")
end
热门帖子
热门github
1
2
3
5
6
7
8
11
13
14
15
Mamba is a new state space model architecture showing promising performance on information-dense data such as language modeling, where previous subquadratic models fall short of Transformers. It is based on the line of progress on structured state space models, with an efficient hardware-aware design and implementation in the spirit of FlashAttention.
(翻译：Mamba 是一种新的状态空间模型架构，在信息密集型数据（例如语言建模）上显示出良好的性能，而之前的二次模型在 Transformers 方面存在不足。它基于结构化状态空间模型的进展，并本着FlashAttention的精神进行高效的硬件感知设计和实现。)
如果我不知道在什么时间之后作业应该关闭，该如何修改此代码。您正在使用2秒，这种情况下很好。但是，如果process_node是更复杂的函数呢？
一种可能的解决方案是使用一些特殊的值/类型来标记要处理的有效值的结尾并关闭通道，我将更新我的答案。