(new ThreadGroupManager(runnables, adminMaxThreadCount, new ThreadWatcher(runnables.length)) {
public void fireStartEvent(ThreadWatcher threadWatcher) {
fireServiceEvent(DeleteObjectsEvent.newStartedEvent(threadWatcher, uniqueOperationId));
}
public void fireProgressEvent(ThreadWatcher threadWatcher, List completedResults) {
objectsToDeleteList.removeAll(completedResults);
S3Object[] deletedObjects = (S3Object[]) completedResults
.toArray(new S3Object[completedResults.size()]);
fireServiceEvent(DeleteObjectsEvent.newInProgressEvent(threadWatcher, deletedObjects, uniqueOperationId));
}
public void fireCancelEvent() {