gistfile1.java

resultCheckerExecutor.execute(
	new Runnable() {
		@Override
		public void run() {
			while (true) {
				try {
					Task saved = taskDao.getById(task.getId());
					assertNotNull(saved);
					if (saved.getState().equals(TaskState.ERROR)) {
						assertNull(saved.getFinished());
						assertNotNull(saved.getStarted());
						resultSemaphore.release();
						break;
					}

					try {
						Thread.sleep(PAUSE_TIME);
					} catch (InterruptedException e) {}
				} catch (Exception e) {
					log.error("Error in result checker", e);
				}
			}
		}
	}
);