Java ScheduledFuture 执行异步任务等到完成

Question

为了以固定速率异步发送大型电子邮件，我使用ScheduledExecutorService。

我有一个实现Runnable 的类，它异步发送邮件。它需要每秒被调用一次，并且恰好 x 次。对于实际发送，我使用Simple Java Mail。我调用的方法是EmailBuilder#send(mail, /* boolean async */ true)。

一旦这个方法被调用了 x 次，ScheduledExecutorService#shutdown() 就会被调用。

我想要的是能够确定所有计划的 Runnables 在哪个时间点终止，即所有 EmailBuilder#send(mail, /* boolean async */ true) 调用都已返回。

我尝试了 ScheduledExecutorService#awaitTermination() 和 ScheduledFuture#get() 超时，但它不起作用或引发了一些异常。

package playground;

import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.ScheduledFuture;
import java.util.concurrent.TimeUnit;

import org.simplejavamail.email.Email;
import org.simplejavamail.email.EmailBuilder;
import org.simplejavamail.mailer.Mailer;
import org.simplejavamail.mailer.MailerBuilder;

public class MCVE {

    private ScheduledExecutorService scheduler;
    private SendTask sd;
    private ScheduledFuture<?> sf;
    private boolean terminateFlag = false;

    public void start() {
        sd = new SendTask();
        scheduler = Executors.newSingleThreadScheduledExecutor();
        sf = scheduler.scheduleAtFixedRate(sd, 0, 1, TimeUnit.SECONDS);
    }

    private class SendTask implements Runnable {

        @Override
        public void run() {
            Mailer mailer = MailerBuilder.withSMTPServer("smtp.gogglemail.com", 587).buildMailer();

            Email mail = EmailBuilder.startingBlank()
                .from("from@gmail.com")
                .to("to@gmail.com")
                .withSubject("Subject")
                .withPlainText("Content")
                .buildEmail();

            mailer.sendMail(mail, /* async */ true);

            if (terminateFlag) {
                sf.cancel(true);
                scheduler.shutdown();
                return;
            }
        }
    }

}

感谢您提供有用的建议！

Answer 1

收集所有在collection中调度后返回的future，然后foreach get()。

Answer 2

sf.isCancelled() 呢？这不是您要找的东西？