AsyncJobOperatorImpl implements JobOperator { protected void pollingSleep() { try { TimeUnit.MILLISECONDS.sleep(jobIntervalTime); } catch (InterruptedException e) { throw new BatchException(e); } } AsyncJobOperatorImpl(JobControlFinder jobControlFinder,
            AsyncJobLauncher asyncJobLauncher,
            AsyncBatchStopper asyncBatchStopper); @Override int start(String[] args);  }
@Test public void testPollingSleep01() throws Exception { Thread.interrupted(); AsyncJobOperatorImpl asyncJobOperator = new AsyncJobOperatorImpl( jobControlFinder, asyncJobLauncher, asyncBatchStopper); asyncJobOperator.jobIntervalTime = 1L; asyncJobOperator.pollingSleep(); }
@Test public void testPollingSleep02() throws Exception { AsyncJobOperatorImpl asyncJobOperator = new AsyncJobOperatorImpl( jobControlFinder, asyncJobLauncher, asyncBatchStopper); asyncJobOperator.jobIntervalTime = 1L; Thread.currentThread().interrupt(); try { asyncJobOperator.pollingSleep(); fail(); } catch (BatchException e) { assertTrue(e.getCause() instanceof InterruptedException); } }