Merge pull request JuliaLang#15513 from JuliaLang/amitm/corrections

minor corrections in WorkerPool and map iterators

base/mapiterator.jl

@@ -47,15 +47,15 @@ wait(state::AsyncMapState) = wait(state.task_done)
 
 # Open a @sync block and initialise iterator state.
 function start(itr::AsyncMapIterator)
- Base.sync_begin()
+ sync_begin()
  AsyncMapState(start(itr.arg_enum), 0, Condition(), false)
 end
 
 # Close @sync block when iterator is done.
 function done(itr::AsyncMapIterator, state::AsyncMapState)
  if !state.done && done(itr.arg_enum, state.enum_state)
  state.done = true
- Base.sync_end()
+ sync_end()
  end
  return state.done
 end

base/workerpool.jl

@@ -3,6 +3,9 @@
 
 type WorkerPool
  channel::RemoteChannel{Channel{Int}}
+
+ # Create a shared queue of available workers...
+ WorkerPool() = new(RemoteChannel(()->Channel{Int}(typemax(Int))))
 end
 
 
@@ -11,10 +14,10 @@ end
 
 Create a WorkerPool from a vector of worker ids.
 """
-function WorkerPool(workers=Int[])
+function WorkerPool(workers::Vector{Int})
 
  # Create a shared queue of available workers...
- pool = WorkerPool(RemoteChannel(()->Channel{Int}(128)))
+ pool = WorkerPool()
 
  # Add workers to the pool...
  for w in workers