Jak uzyskać terminarz akka wewnątrz pętli dla aktualnego ouput

Question

Mam funkcjonalność do zrobienia czegoś przez timer wewnątrz pętli. Więc pomyślałem o użyciu programu planującego akka, aby to osiągnąć. Oto mój przykładowy kod (napisany wewnątrz aktora Akka):

class TestActor extends Actor { 

    override def receive: Receive = { 
    case num: Int => println(num) 
    case Tick => loopAndPrint 
    } 

    def loopAndPrint = { 
    val list = List(1, 100, 5, 23) 
    list.map { l => 
     context.system.scheduler.scheduleOnce(Duration.create(30, TimeUnit.SECONDS), self, l) 
    } 
    } 

} 

Spodziewałem się, że println zostanie wywołana co 30 sekund do końca listy. Zaczęło się jednak po 30 sekundach i kończyło się drukowaniem wszystkich pozycji listy na raz.

Jak mogę to osiągnąć, aby wydrukować elementy listy co 30 sekund po starcie?

Z góry dziękuję.

Answer 1

Wygląda na to, że zapętlisz całą wartość Integer i zaplanujesz wydruk każdego z nich po 30 sekundach na raz. Spróbuj zwiększyć czas trwania do 30 dla każdej pętli.

class TestActor extends Actor { 

    override def receive: Receive = { 
    case num: Int => println(num) 
    case Tick => loopAndPrint 
    } 

    def loopAndPrint = { 
    val list = List(1, 100, 5, 23) 
    list.foldLeft(30)((t, l)=> { 
     context.system.scheduler.scheduleOnce(Duration.create(t, TimeUnit.SECONDS), self, l) 
     t + 30 
    }) 
    } 

}