code: void selectJobsToInitialize() {
      for (String queue : jobQueues.keySet()) {
        ArrayList<JobInProgress> jobsToInitialize = getJobsToInitialize(queue);
        printJobs(jobsToInitialize);
        JobInitializationThread t = threadsToQueueMap.get(queue);
        for (JobInProgress job : jobsToInitialize) {
          t.addJobsToQueue(queue, job);
        }
      }
    }
docs: The key method which does selecting jobs to be initalized across
  queues and assign those jobs to their appropriate init-worker threads.
  <br/>
  This method is overriden in test case which is used to test job
  initialization poller.