У меня есть набор поставщиков, которые все дают один и тот же результат, но с другой (и переменной) скоростью.
Я хочу элегантный способ начать работу с поставщиками одновременно, и как только один из них получит значение, верните его (отбрасывая другие результаты).
Я попытался использовать параллельные потоки и Stream.findAny()
для этого, но он всегда блокируется до тех пор, пока не будут созданы все результаты.
Здесь unit test, демонстрирующий мою проблему:
import org.junit.Test;
import java.util.Collections;
import java.util.Optional;
import java.util.Set;
import java.util.concurrent.ConcurrentHashMap;
import java.util.function.Supplier;
import java.util.stream.Stream;
import static org.junit.Assert.*;
public class RaceTest {
@Test
public void testRace() {
// Set up suppliers
Set<Supplier<String>> suppliers = Collections.newSetFromMap(new ConcurrentHashMap<>());
suppliers.add(() -> "fast"); // This supplier returns immediately
suppliers.add(() -> {
try {
Thread.sleep(10_000);
return "slow";
} catch (InterruptedException e) {
throw new RuntimeException(e);
}
}); // This supplier takes 10 seconds to produce a value
Stream<Supplier<String>> stream = suppliers.parallelStream();
assertTrue(stream.isParallel()); // Stream can work in parallel
long start = System.currentTimeMillis();
Optional<String> winner = stream
.map(Supplier::get)
.findAny();
long duration = System.currentTimeMillis() - start;
assertTrue(winner.isPresent()); // Some value was produced
assertEquals("fast", winner.get()); // The value is "fast"
assertTrue(duration < 9_000); // The whole process took less than 9 seconds
}
}
Результат теста заключается в том, что последнее утверждение не выполняется, так как весь тест занимает около 10 секунд.
Что я здесь делаю неправильно?