如何在循环内实现akka调度器以获得及时的输出

import akka.actor.AbstractActor;
import akka.actor.ActorRef;
import akka.actor.ActorSystem;
import akka.actor.Cancellable;
import scala.concurrent.duration.Duration;

import java.util.concurrent.TimeUnit;

public class MyActor extends AbstractActor {
    private Cancellable scheduler;

    @Override
    public void preStart() throws Exception {
        super.preStart();
        ActorSystem system = getContext().getSystem();
        scheduler = system.scheduler().schedule(
                Duration.Zero(), // 延迟时间
                Duration.create(1, TimeUnit.SECONDS), // 间隔时间
                self(), // 发送消息的Actor
                "Hello", // 消息内容
                system.dispatcher(), // 使用默认的调度器
                ActorRef.noSender() // 消息接收者
        );
    }

    @Override
    public Receive createReceive() {
        return receiveBuilder()
                .match(String.class, message -> {
                    // 处理接收到的消息
                    System.out.println(message);
                })
                .build();
    }
}