code: public void setupInstances() {
  		this.piInstances = new ArrayList<ThreadsProcessingItemInstance>(this.getParallelism());
  		for (int i=0; i<this.getParallelism(); i++) {
  			Processor newProcessor = this.getProcessor().newProcessor(this.getProcessor());
  			newProcessor.onCreate(i + 1);
  			this.piInstances.add(new ThreadsProcessingItemInstance(newProcessor, this.offset + i));
  		}
  	}
docs: /*
  Setup the replicas of this PI.
  This should be called after the topology is set up (all Processors and PIs are
  setup and connected to the respective streams) and before events are sent.