DistributedArrays.jl
DistributedArrays.jl copied to clipboard
JuliaParallel
Distributed Arrays in Julia
I ran into an issue when running this block of code: ``` using Distributed if nprocs() == 1 addprocs() end @everywhere using DistributedArrays a = dfill([], 20) @sync @distributed for...
The following example creates DArrays `A` and `x`, then attempts `A*x`. The only unusual bit is that `A` is distributed unevenly. ``` # test.jl using Distributed, DistributedArrays @everywhere using Distributed,...
The following code does not infer properly: ```julia using DistributedArrays addprocs(1) a = distribute(rand(10), procs = [1,2]) f(x) = log.(x) @code_warntype f(a) @code_warntype map(log, a) ```
I was getting nervous about the communication costs of being imprecise with communications outside of the localpart of the array, so I figured I'd build a halo exchange system by...
When building the remotely the array as specified in the [documentation](https://juliaparallel.github.io/DistributedArrays.jl/stable/#Construction-from-arrays-generated-on-separate-processes-1): ```julia ras = [@spawnat p wrong_name() for p in workers()[1:4]] ras = reshape(ras,(2,2)) D = DArray(ras) ``` Assuming the...
```julia julia> d = dzeros((3,3)) 3×3 DArray{Float64,2,Array{Float64,2}}: 0.0 0.0 0.0 0.0 0.0 0.0 0.0 0.0 0.0 julia> d2 = dzeros((3,3,1)) 3×3×1 DArray{Float64,3,Array{Float64,3}}: [:, :, 1] = 0.0 0.0 0.0 0.0...
I am wondering why it is not possible to gather a DArray{T,N,Array{T,N}}? I wrote this method to the gather function, it works for my purpose. Maybe it is possible to...
It seems like there is a conflict between localindices method between SharedArrays and DistributedArrays. Please, see the REPL output below. 10:46:39 $ julia-1.0 _ _ _ _(_)_ | Documentation: https://docs.julialang.org...
Hello, Consider the following example: ``` @everywhere struct SS1 v::Vector{Float64} m::Vector{Float64} end dSS=@DArray [SS1(rand(10),i*ones(10)) for i in 1:10] dSS2=@DArray [SS1(rand(10^6),i*ones(10)) for i in 1:10]; @time dSS[2].m @time dSS2[2].m; 0.004819 seconds...
