update data download
@@ -133,8 +133,6 @@ public class DownloadThreadManager implements Callable<Boolean> {
break;
}
}
- }
-
for (FutureTask<ResultMessage> task : futures) {
ResultMessage result = null;
try {
@@ -158,6 +156,9 @@ public class DownloadThreadManager implements Callable<Boolean> {
blockQueue.offer(block);
}
}
+ futures.clear();
+ }
+
executor.shutdown();
return true;
