anchor.diff:  % number of unique processes a channel sees could be the max batch size).
   -define(BATCH_SIZE_MAX, 20). 
   
  +% It may be useful to run through the batch multiple times before asking for a
  +% new one. The batch replay constant multiplies with the number of processes
  +% currently in the queue to produce the number of 'rounds' to run before giving
  +% up the batch.
  +-define(BATCH_REPLAY, 1).
  +
   %% Process inspection operations:
   -include("process.hrl").
   
  
positive.code:     case enqueue_then_pop_push( C, LD, Ps ) of
          {ok, ProcessBatch} ->
              {ok, running, resetCur( ProcessBatch, State )};
          false -> {ok, waiting, State#state{loading_dock=nil}}
      end;
  pick_new_sq( #state{cur_proc=nil,loading_dock=LD,rounds=R,procs=Ps}=State ) ->
      case queue:len( LD ) of
          0 -> 
              (case erlam_private_queue:pop( Ps ) of
                   false -> {ok, waiting, State#state{loading_dock=nil}};
                   {ok,NewLD} -> {ok, running, resetCur( NewLD, State )}
               end);
          _ -> 
  
negative.code: %% @end
  resetCur( Batch, #state{ max_reduc=MR } = State ) ->
      {{value,Top},NewBatch} = queue:out(Batch),
      Rounds = queue:len(Batch) * State#state.batch_replay,
      State#state{cur_proc=Top, cur_reduc=MR,
                  loading_dock=NewBatch, rounds=Rounds}.
  
  %% @hidden
  %% @doc Blanks out a state in the event of completely stolen processes or
  %%   when a large set of processes stop.
  %% @end
  blankOut( State ) ->
      State#state{ cur_proc=nil, cur_reduc=0,
                   loading_dock=nil, rounds=0 }.
  
  