Skip to content

Commit d1c8f18

Browse files
committed
custom progress description
1 parent 4328b98 commit d1c8f18

File tree

2 files changed

+4
-3
lines changed

2 files changed

+4
-3
lines changed

Project.toml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
name = "ParallelUtilities"
22
uuid = "fad6cfc8-4f83-11e9-06cc-151124046ad0"
33
authors = ["Jishnu Bhattacharya <[email protected]>"]
4-
version = "0.6.0"
4+
version = "0.6.1"
55

66
[deps]
77
Distributed = "8ba89e20-285c-5b6f-9357-94700520ee1b"

src/ParallelUtilities.jl

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -857,13 +857,14 @@ end
857857
@inline return_unless_error(b::BranchChannel) = return_unless_error(b.parentchannels)
858858

859859
function pmapreduceworkers(fmap::Function,freduce::Function,iterators::Tuple,
860-
branches,ord::Ordering,args...;kwargs...)
860+
branches,ord::Ordering,args...;
861+
progressdesc="Progress in pmapreduce : ",kwargs...)
861862

862863
num_workers_active = nworkersactive(iterators)
863864

864865
nmap,nred = 0,0
865866
progresschannel = RemoteChannel(()->Channel{Tuple{Bool,Bool}}(2num_workers_active))
866-
progressbar = Progress(2num_workers_active,1,"Progress in pmapreduce : ")
867+
progressbar = Progress(2num_workers_active,1,progressdesc)
867868

868869
# Run the function on each processor and compute the reduction at each node
869870
@sync begin

0 commit comments

Comments
 (0)