diff --git a/src/altk/comm/engine/Broadcast.java b/src/altk/comm/engine/Broadcast.java index d0d065f..bfa28f6 100644 --- a/src/altk/comm/engine/Broadcast.java +++ b/src/altk/comm/engine/Broadcast.java @@ -1155,8 +1155,7 @@ public abstract class Broadcast || state == BroadcastState.PAUSING ) { - //remainingJobs--; - completedJobCount++; + incrementCompletedCount(); logJobCount("Completed a job"); if (getRemainingJobCount() == 0) @@ -1181,6 +1180,11 @@ public abstract class Broadcast } } + synchronized private void incrementCompletedCount() + { + completedJobCount++; + } + /** * Logs effectiveJobCount, completedJobCount, readyQueue.size(), * active job count, and total which recipientList.size()