Julia中@sync @parallel循环调用函数时UndefVarError问题排查

这其实是Julia多进程并行场景里常见的作用域与变量同步问题，我来给你拆解清楚：

为什么示例1无法运行？ #

先看你的无法运行的代码：

@everywhere function test_fun(arg) println(arg); end
flag = 1;
if flag == 1
    asd = 123;
    @sync @parallel for i=1:10
        test_fun(asd);
    end
end

这里的asd是定义在if代码块的局部作用域里的，只有当前主进程能看到这个变量。而@parallel会把循环任务分发到各个工作进程，这些进程并没有同步到这个局部变量，执行时自然会找不到asd，导致报错。

示例2为什么能正常运行？ #

再看可运行的版本：

@everywhere function test_fun(arg) println(arg); end
asd = 123;
@sync @parallel for i=1:10
    test_fun(asd);
end

此时asd是定义在全局作用域中的，Julia会自动将全局作用域的变量同步到所有工作进程，所以各个进程都能拿到asd的值，并行循环就能正常调用test_fun了。

解决办法：用@everywhere显式同步变量 #

你提到的@everywhere asd = 123;确实是最直接的解决方案，它会把变量的定义广播到所有已启动的工作进程，确保每个进程都能访问到这个变量：

@everywhere function test_fun(arg) println(arg); end
flag = 1;
if flag == 1
    @everywhere asd = 123;
    @sync @parallel for i=1:10
        test_fun(asd);
    end
end

如果你的变量值是动态计算出来的，也可以先在主进程计算好，再用@everywhere同步：

@everywhere function test_fun(arg) println(arg); end
flag = 1;
if flag == 1
    local_val = 123  # 主进程内计算值
    @everywhere asd = $local_val  # 把主进程的变量值同步到所有工作进程
    @sync @parallel for i=1:10
        test_fun(asd);
    end
end

内容的提问来源于stack exchange，提问作者merch