代码之家 › 专栏 › 技术社区 › Richard

调用函数的工作进程未打印

julia

0

Richard · 技术社区 · 7 年前

我正在尝试调试Julia中的一个并行程序,希望看到它的工作人员打印出来的结果,但他们似乎无法打印出来。我怎样才能“修复”这个?

我的测试代码是:

function Test()
  print("Worker ",myid())
end

for i in workers()
  @spawnat i Test()
end

1 回复 | 直到 7 年前

1

2

Przemyslaw Szufel 7 年前

功能 Test 未在远程工作者上定义,您不使用 fetch 因此它无声地失败了。使用 myid() 还需要加载 Distributed 在远程工作人员。最后但并非最不重要的是,远程工作者的标准输出缓存在行级别,因此需要使用 println 而不是 print .

以下是正确的代码:

using Distributed
@everywhere Distributed
@everywhere function Test()
    println("Worker ",myid())
end

for i in workers()
    fetch(@spawnat i Test())
end

博古米尔的评论- 取来 在这里,您的代码不会因为其他原因而自动失败。您需要使用@async和@sync宏来收集数据:

jobs = Dict{Int,Future}()
@sync for i in workers()
    @async jobs[i] = @spawnat i Test()
end

@sync for i in workers()
    @async fetch(jobs[i])
end