Skip to content
This repository has been archived by the owner on Jan 6, 2019. It is now read-only.

Commit

Permalink
fix to previous commit[2]
Browse files Browse the repository at this point in the history
  • Loading branch information
edgarvperes committed Dec 26, 2015
1 parent 7d5086b commit 8f0283f
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -68,8 +68,8 @@ public void destroyAllConsumers(boolean finishCurrentTasks, boolean blockUntilFi
if (!finishCurrentTasks) removeAllTasks();

synchronized (mWaitingUntilAllFinishedLock) {
mConsumersShouldDie = true;
int threadsToKill = mNumThreadsAlive;
mConsumersShouldDie = true;
DieTask dieTask = new DieTask();
for (int i = 0; i < threadsToKill; i++) {
mTasks.add(dieTask);
Expand Down

0 comments on commit 8f0283f

Please sign in to comment.