parallel-processing - 如何在 Julia 中同时写入数组的多个索引？

Question

我希望在 Julia 中看到这样的事情:

using Distributed
addprocs(4)

@everywhere arr = Array{Int}(undef, 10)
for i = 1:10
    @spawn arr[i] = i
end

这样做的正确方法是什么？

Answer 1

您可以通过以下方式并行化该过程。

线程(需要设置 JULIA_NUM_THREADS 系统变量)

arr = Array{Int}(undef, 10)
Threads.@threads for i = 1:10
    arr[i] = i
end

SharedArrays

using Distributed, SharedArrays
addprocs(4)
arr = SharedVector{Int}(10)
@sync @distributed for i in 1:10
    arr[i] = i 
end

请注意，一个常见的错误是忘记放置 @sync之前 @distributed没有聚合器功能(见最后一个例子)。

聚合分布式计算的结果

using Distributed
addprocs(4)
arr = @distributed (append!) for i in 1:10
    [i]
end