mirror of
https://github.com/nosqlbench/nosqlbench.git
synced 2025-02-25 18:55:28 -06:00
updated release notes
This commit is contained in:
parent
13e6d74e0a
commit
eeba6fdf05
@ -1,2 +1,7 @@
|
||||
a8bee9c7 (HEAD -> master) update kafka module versions
|
||||
f2240746 minor refinements to kafka producer
|
||||
13e6d74e (HEAD -> master) move tests to correct package
|
||||
370de82a fix docs sorting bug
|
||||
bf7240d7 added kafka producer
|
||||
a8bee9c7 update kafka module versions
|
||||
f2240746 minor refinements to kafka producer
|
||||
|
@ -0,0 +1,20 @@
|
||||
package io.nosqlbench.engine.core.experimental;
|
||||
|
||||
import org.junit.Test;
|
||||
|
||||
import java.util.concurrent.CompletableFuture;
|
||||
import java.util.concurrent.CompletionStage;
|
||||
import java.util.concurrent.ExecutorService;
|
||||
import java.util.concurrent.Executors;
|
||||
|
||||
public class CompletableTests {
|
||||
|
||||
@Test
|
||||
public void testCompletionStages() {
|
||||
CompletableFuture<Object> f = new CompletableFuture<>();
|
||||
ExecutorService executorService = Executors.newCachedThreadPool();
|
||||
CompletableFuture<Object> objectCompletableFuture = f.completeAsync(() -> "foo", executorService);
|
||||
boolean bar = objectCompletableFuture.complete("bar");
|
||||
|
||||
}
|
||||
}
|
Loading…
Reference in New Issue
Block a user