4 ms·
Why not simply: var input = new HashMap<Integer, String>(); var results = new ConcurrentHashMap<Integer, Document>(); var futures = input.entrySet(
by azth 5y ago
Why not simply:
var input = new HashMap<Integer, String>();
var results = new ConcurrentHashMap<Integer, Document>();
var futures = input.entrySet().stream().map(entry ->
CompletableFuture.runAsync(() -> {
var sentiment = getSentiment(entry.getValue());
results.put(entry.getKey(), new Document(entry.getKey(), sentiment));
})
);
CompletableFuture.allOf(futures.toArray(CompletableFuture[]::new)).join();
Let us know what the speedup is :)