anchor.diff:                          let! workerCount = 
                               match collector.DegreeOfParallelism with
                               | Some n -> local { return n }
  -                            | _ -> Cloud.GetWorkerCount() 
  +                            | _ -> Cloud.GetWorkerCount()
  +                        let! workers = Cloud.GetAvailableWorkers() 
   
                           let createTask (files : CloudFile []) (collectorf : Local<Collector<'T, 'S>>) : Local<'R> = 
                               local {
  
positive.code:                             | Some n -> return n
                              | None -> return! Cloud.GetWorkerCount()
                          }
  
                          // TODO : need a scheduling algorithm to assign partition indices
                          //        to workers according to current cache state.
  
negative.code:                         match collector.DegreeOfParallelism with
                          | Some n -> local { return n }
                          | _ -> Cloud.GetWorkerCount()
                      let! workers = Cloud.GetAvailableWorkers()
  
                      let createTask array (collector : Local<Collector<'T, 'S>>) = 
                          local {
  