in 2-advanced/dubbo-samples-async/dubbo-sample-async-generated-future-springboot/dubbo-samples-async-generated-future-springboot-consumer/src/main/java/org/apache/dubbo/async/springboot/consumer/Task.java [35:49]
public void run(String... args) throws Exception {
new Thread(() -> {
while (true) {
try {
CompletableFuture<String> future = greetingService.greeting("async call request", SIGNAL);
System.out.println("async call returned: " + future.get());
System.out.println(greetingService.greeting("normal sync call request"));
Thread.sleep(1000);
} catch (Throwable t) {
t.printStackTrace();
}
}
}).start();
}