parallel-processing - julia 任务中的变量范围

Question

我已将 pmap() 实现调整到我的程序中以进行一些调度，并且我对任务中变量的范围有疑问。这是 Julia 的实现

function pmap(f, lst)
    np = nprocs()  # determine the number of processes available
    n = length(lst)
    results = cell(n)
    i = 1
    # function to produce the next work item from the queue.
    # in this case it's just an index.
    nextidx() = (idx=i; i+=1; idx)
    @sync begin
        for p=1:np
            if p != myid() || np == 1
                @async begin
                    while true
                        idx = nextidx()
                        if idx > n
                            break
                        end
                        results[idx] = remotecall_fetch(p, f, lst[idx])
                    end
                end
            end
        end
    end
    results
end

如果我将 idx = nextidx() 行替换为 idx=x; i=i+1; ，每个任务更新变量 i 的本地副本。然而，函数 nextidx() 中的变量 i 由所有任务共享。为什么是这样？

Answer 1

我先把上面的代码简化一下:

function test()
  i=10
  nexti() = (inx=i;i+=1;inx)
  @sync begin
    @async begin
      i=i+10
      nexti()      
      println("value of i in another thread => $i")
    end
  end
  println("value of i in test() => $i")
end

test()

# value of i in another thread => 20
# value of i in test() => 11

我们声明 nexti()在与 i 相同的过程中已声明，并且 i在 nexti()指的是相同的位置，因此对 i 的任何更改内 nexti()警报 i外部作用域中的值。

另一方面，@async 宏强制内部的块在不同的进程上运行，因此该块使用 i 的副本值和此块内的任何更改都不会发出警报 i外部作用域中的值。