最近我试图实现一个电子邮件服务,同时向每个用户发送电子邮件。我当前的实现电流看起来像这样:
ExecutorService executor = Executors.newSingleThreadExecutor();
tasks.forEach(executor::execute); // Each task sends an email to an user
executorService.shutdown(); // Reclaim all the resources
经过一番研究,我找到了一种新方法,即使用 Java 8CompletableFuture.runAsync(...)方法。使用这种方法我做了:
ExecutorService executor = Executors.newSingleThreadExecutor();
tasks.forEach(task -> CompletableFuture.runAsync(task, executor));
executor.shutdown(); // Reclaim all resources
现在我有点困惑,就正确性、可扩展性而言,解决我的问题的最佳方法是什么,以及解决我的问题的最现代/当前的方法是什么。
精慕HU
相关分类