Акка Актер LifeCycle - PullRequest
       12

Акка Актер LifeCycle

0 голосов
/ 31 мая 2018

Я использую Akka Java API 2.5.12.Я хочу реализовать push sender .Я использую бесконечный цикл с задержкой в ​​одну секунду, и в каждой итерации я получаю 50 нажатий из базы данных, используя Hikari Datasource Connection Pool.Затем я перебираю этот список из 50 нажатий, и на каждой итерации я создаю новый Actor следующим образом:

final ActorRef pushSenderActor = system.actorOf(PushSenderAktor.props());
pushSenderActor.tell(push, ActorRef.noSender());

Затем PushSenderAktor играют свою роль и отправляют push-сообщения асинхронно.

Мой вопрос: Нужно ли останавливать актера после того, как он выполнил отправку push методом context().stop(getSelf());, или этот актер покончит с собой после выполнения своего метода createReceive()? Поскольку я нене хочу содержать HollyWood в моей системе ActorSystem.

1 Ответ

0 голосов
/ 01 июня 2018

Вам нужно будет явно остановить или отправить PoisonPill

https://doc.akka.io/docs/akka/2.5/actors.html#actor-lifecycle

Также рассмотрите возможность использования планировщика в актере верхнего уровня в обычной работе и рассмотрите возможность держать актеров рядом и использоватьих как долгосрочные работники.

...