(new ThreadGroupManager(runnables, adminMaxThreadCount, new ThreadWatcher(runnables.length)) {
public void fireStartEvent(ThreadWatcher threadWatcher) {
fireServiceEvent(CreateBucketsEvent.newStartedEvent(threadWatcher, uniqueOperationId));
}
public void fireProgressEvent(ThreadWatcher threadWatcher, List completedResults) {
incompletedBucketList.removeAll(completedResults);
S3Bucket[] completedBuckets = (S3Bucket[]) completedResults
.toArray(new S3Bucket[completedResults.size()]);
fireServiceEvent(CreateBucketsEvent.newInProgressEvent(threadWatcher, completedBuckets, uniqueOperationId));
}
public void fireCancelEvent() {