Julia：在另一个文件中调用并行循环

Question

假设我有这两个文件。

test_file.jl

using Distributed
function loop(N)
  @distributed for i in 1:N
          println(i)
  end
end

test_file_call.jl

include("test_file.jl")
loop(10)

如果我运行 julia -p 2 test_file_call.jl，我希望函数 loop 在不同的处理器上执行，打印出任意数字的 10 个数字。但是，此命令不呈现任何内容。

我不确定我做错了什么？这只是一个简单的循环。是否有可能我在文件 A 中包含一个并行循环，编写另一个包含此循环的文件 B，然后调用 B 来执行文件 A 中的并行循环？这两个文件结构是我想要的。这可行吗？

Answer 1

问题是您忘记了 @sync 循环，因此它在实际有时间打印任何内容之前就退出了。

因此这应该是：

function loop(N)
  @sync @distributed for i in 1:N
      println(i, " ",myid())
  end
end

Julia: call a parallel loop in another file