java - 使用 Speedment Streams 进行异步回调

Question

我正在缓慢的连接上运行，并且我想在数据库中有新实体可用时设置带有回调的 Speedment Stream。我该怎么做？

Answer 1

这是一种实现方法:

public class Main {

    public static void main(String[] args) {

        DemoApplication app = new DemoApplicationBuilder()
            .withPassword("mySecretPw")
            .build();

        final Manager<Country> countries =    
             app.getOrThrow(CountryManager.class);

        ForkJoinPool.commonPool().submit(
            () -> countries.stream().forEach(Main::callback)
        );

    }

    private static void callback(Country c) {
        System.out.format("Thread %s consumed %s%n",         
            Thread.currentThread().getName(), c);
    }

}

当然，您可以向 ForkJoinPool 提供任何流。例如，如果您只想在回调中接收名称以“A”开头的前十个国家/地区，那么您可以编写:

ForkJoinPool.commonPool().submit(
    () -> countries.stream()
        .filter(Country.NAME.startsWith("A"))
        .limit(10)
        .forEach(Main::callback)
);