issue #865 resolution

emc-mongoose · Nov 23, 2016 · c0501d6 · c0501d6
1 parent add8081
commit c0501d6
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/src/main/java/com/emc/mongoose/core/impl/load/executor/LoadExecutorBase.java b/src/main/java/com/emc/mongoose/core/impl/load/executor/LoadExecutorBase.java
@@ -181,6 +181,10 @@ public final void run() {
 				while(!currThread.isInterrupted()) {
 					postProcessItems();
 					LockSupport.parkNanos(1_000);
+					if(isDone()) {
+						isPostProcessDone = true;
+					}
+					LockSupport.parkNanos(1_000);
 				}
 			} catch(final InterruptedException e) {
 				LogUtil.exception(LOG, Level.ERROR, e, "Interrupted");
@@ -211,8 +215,8 @@ protected void postProcessItems()
 				} else {
 					postProcessUniqueItemsFinally(items);
 				}
-			} else if(isDone()) {
-				isPostProcessDone = true;
+			} else {
+				LockSupport.parkNanos(1_000);
 			}
 		} catch(final IOException e) {
 			LogUtil.exception(