It is obvious that the constructed list of futures is never going to be
used, so let's not construct it at all.
Change-Id: I506e33da52c53b5e63088a5c8ae0bb206eb6a720
Signed-off-by: Robert Varga <rovarga@cisco.com>
import java.util.Collections;
import java.util.Set;
import java.util.concurrent.ExecutorService;
import java.util.Collections;
import java.util.Set;
import java.util.concurrent.ExecutorService;
-import java.util.concurrent.Future;
import org.eclipse.xtext.xbase.lib.Conversions;
import org.eclipse.xtext.xbase.lib.Functions.Function1;
import org.eclipse.xtext.xbase.lib.Conversions;
import org.eclipse.xtext.xbase.lib.Functions.Function1;
import com.google.common.base.Preconditions;
import com.google.common.collect.HashMultimap;
import com.google.common.base.Preconditions;
import com.google.common.collect.HashMultimap;
-import com.google.common.collect.ImmutableSet;
-import com.google.common.collect.ImmutableSet.Builder;
import com.google.common.collect.Iterables;
import com.google.common.collect.Multimap;
import com.google.common.collect.Multimaps;
import com.google.common.collect.Iterables;
import com.google.common.collect.Multimap;
import com.google.common.collect.Multimaps;
};
final Set<NotifyTask> tasks = IterableExtensions.<NotifyTask>toSet(
IterableExtensions.<NotificationListener<?>, NotifyTask>map(listenerToNotify, _function));
};
final Set<NotifyTask> tasks = IterableExtensions.<NotifyTask>toSet(
IterableExtensions.<NotificationListener<?>, NotifyTask>map(listenerToNotify, _function));
- this.submitAll(executor, tasks);
- }
- private ImmutableSet<Future<Object>> submitAll(final ExecutorService service, final Set<NotifyTask> tasks) {
- final Builder<Future<Object>> ret = ImmutableSet.<Future<Object>>builder();
for (final NotifyTask task : tasks) {
for (final NotifyTask task : tasks) {
- ret.add(service.submit(task));