From 25281b236e7d8fa3adb4440c927c972f79dcd439 Mon Sep 17 00:00:00 2001 From: dsyer Date: Tue, 1 Apr 2008 10:31:55 +0000 Subject: [PATCH] Comments added to clarify TaskExecutorRepeatTemplate --- .../batch/repeat/support/TaskExecutorRepeatTemplate.java | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/spring-batch-infrastructure/src/main/java/org/springframework/batch/repeat/support/TaskExecutorRepeatTemplate.java b/spring-batch-infrastructure/src/main/java/org/springframework/batch/repeat/support/TaskExecutorRepeatTemplate.java index 449bf1808..cafef0a11 100644 --- a/spring-batch-infrastructure/src/main/java/org/springframework/batch/repeat/support/TaskExecutorRepeatTemplate.java +++ b/spring-batch-infrastructure/src/main/java/org/springframework/batch/repeat/support/TaskExecutorRepeatTemplate.java @@ -122,6 +122,11 @@ public class TaskExecutorRepeatTemplate extends RepeatTemplate { */ } while (queue.isEmpty() && !isComplete(context)); + /* + * N.B. If the queue is empty then take() blocks until a result appears, + * and there must be at least one because we just submitted one to teh + * task executor. + */ ResultHolder result = queue.take(); if (result.getError() != null) { throw result.getError();