(new ThreadGroupManager(runnables, maxThreadCount, threadWatcher, ignoreExceptions) {
public void fireStartEvent(ThreadWatcher threadWatcher) {
fireServiceEvent(DownloadObjectsEvent.newStartedEvent(threadWatcher, uniqueOperationId));
}
public void fireProgressEvent(ThreadWatcher threadWatcher, List completedResults) {
incompleteObjectDownloadList.removeAll(completedResults);
S3Object[] completedObjects = (S3Object[]) completedResults
.toArray(new S3Object[completedResults.size()]);
fireServiceEvent(DownloadObjectsEvent.newInProgressEvent(threadWatcher, completedObjects, uniqueOperationId));
}
public void fireCancelEvent() {