@Test(timeout = 1000L)
public void Should_exit_When_threadIsInterrupted()
        throws Exception {

    ExecutionTaskWithStrategy executionTask = new ExecutionTaskWithStrategy(dispatcherMock, processStrategyMock);
    when(dispatcherMock.getExecutionTask()).thenReturn(executionTask);
    Thread.currentThread().interrupt();
    executionTask.execute();
    verify(queueMock, never()).tryTake();
    assertTrue(Thread.interrupted());
}