diff --git a/src/foldssum.jl b/src/foldssum.jl index e3cf4a8..4e1a055 100644 --- a/src/foldssum.jl +++ b/src/foldssum.jl @@ -70,7 +70,7 @@ function product(sum::FoldsSum{<:Any,<:DistributedEx}, v::ITensor) end function product(callback, sum::FoldsSum, v::ITensor) - return Folds.sum(terms(sum), executor(sum)) begin term + return Folds.sum(terms(sum), executor(sum)) do term res = term(v) callback() return res @@ -86,7 +86,7 @@ function position!(sum::FoldsSum{<:Any,<:DistributedEx}, v::MPS, pos::Int) end function position!(callback, sum::FoldsSum, v::MPS, pos::Int) - new_terms = Folds.map(term -> position!(term, v, pos), terms(sum), executor(sum)) begin term + new_terms = Folds.map(terms(sum), executor(sum)) do term res = position!(term, v, pos) callback() return res @@ -99,7 +99,7 @@ function noiseterm(sum::FoldsSum, v::ITensor, dir::String) end function noiseterm(callback, sum::FoldsSum, v::ITensor, dir::String) - return Folds.sum(terms(sum), executor(sum)) begin term + return Folds.sum(terms(sum), executor(sum)) do term res = noiseterm(term, v, dir) callback() return res diff --git a/src/force_gc.jl b/src/force_gc.jl index a6fb0d5..b1019a5 100644 --- a/src/force_gc.jl +++ b/src/force_gc.jl @@ -10,7 +10,7 @@ end # https://discourse.julialang.org/t/from-multithreading-to-distributed/101984/6 function force_gc(gb_threshold::Real=get_gc_gb_threshold()) if Sys.free_memory() < gb_threshold * 2^30 - GC.gc() + GC.gc() end return nothing end diff --git a/src/mpisumterm.jl b/src/mpisumterm.jl index 70d2741..5a60dad 100644 --- a/src/mpisumterm.jl +++ b/src/mpisumterm.jl @@ -9,7 +9,7 @@ set_term(sumterm::MPISumTerm, term) = (@set sumterm.term = term) set_comm(sumterm::MPISumTerm, comm) = (@set sumterm.comm = comm) MPISumTerm(mpo::MPO, comm::MPI.Comm) = MPISumTerm(ProjMPO(mpo), comm) -MPISumTerm(mpos::Vector{MPO},comm::MPI.Comm) = MPISumTerm(ProjMPOSum(mpos),comm) +MPISumTerm(mpos::Vector{MPO}, comm::MPI.Comm) = MPISumTerm(ProjMPOSum(mpos), comm) nsite(sumterm::MPISumTerm) = nsite(term(sumterm))