@Override
      public void run() {
        AnalyticJob job4 = spy(new AnalyticJob());
        when(job4.readyForSecondRetry()).thenReturn(false);
        analyticJobGenerator.addIntoSecondRetryQueue(job4);

        // Latch countdown to ensure fetch jobs thread can continue.
        latch.countDown();

        AnalyticJob job5 = spy(new AnalyticJob());
        when(job5.readyForSecondRetry()).thenReturn(true);
        analyticJobGenerator.addIntoSecondRetryQueue(job5);
      }
Tests concurrent operations (fetch and add) on second retry queue.
test/com/linkedin/drelephant/analysis/AnalyticJobGeneratorHadoop2Test.java