ExecutorService executor = Executors.newFixedThreadPool(10);
executor.submit(() -> {
});
executor.shutdown();
Future<String> future = executor.submit(() -> {
return "Hello, world!";
});
String result = future.get();
System.out.println(result);
CompletableFuture.supplyAsync(() -> {
return "Hello, world!";
}).thenAccept(result -> {
});
CompletableFuture.supplyAsync(() -> {
return "Hello, world!";
}).thenApply(result -> {
return "Processed: " + result;
}).thenAccept(result -> {
}).thenRun(() -> {
});
Observable<String> observable = Observable.create(emitter -> {
emitter.onNext("Hello");
emitter.onNext("World");
emitter.onComplete();
});
observable.subscribe(
item -> {
},
error -> {
},
() -> {
}
);
