Планирование повторяющихся заданий с блокировкой операций

Question

У меня есть набор из нескольких заданий Akka, которые работают в разных графиках. Недавно я добавил несколько заданий, которые должны выполняться один раз в день, которые требуют чтения файла с диска и обработки данных. Поскольку чтение с диска является блокировкой, мой код ждет и не выполняет никаких запланированных заданий при выполнении операции расписания. Кто-нибудь знает способ, которым поток планирования не должен блокироваться операциями ввода-вывода ожидающих операций? Я включил код одного из моих действующих лиц ниже.

код планировщика:

lazy val system = akka.actor.ActorSystem("system") 
lazy val emailActor = system.actorOf(Props[EmailActor], name = "EmailActor") 

system.scheduler.schedule(3 hours, 24 hours)(emailActor ! System.currentTimeMillis) 

Реализация актер:

class EmailActor extends Actor { 
    override def receive = { 
    case _ => EmailSyncer.process() 
    } 
} 

Процессор:

def process() = { 
    DataWarehouse.dataWarehouse withSession { 
    val file = "/some/file/name" 
    val emails = Try { Source.fromFile(file).getLines.map(l => Email(l)) } 

    ... 
    } 
} 

Answer 1

Это общая проблема в Акку. И поэтому шаблон для его решения легко доступен. Посмотрите на «Переборку». Я добавил сообщение в блоге ниже, в котором показано, что именно вы должны делать.

Общая идея заключается в том, что вы можете поместить разных участников в различные контексты исполнения или в сленговые «зоны отказа». Это позволяет вам сдерживать истощение ресурсов и другие проблемы от кровотечения в другие части вашего приложения. Только один контекст исполнения поражает голод, больше ничего.

Вы также можете настроить пулы потоков по-разному на основе того, что делает каждая зона отказа. Как правило, большое количество потоков для блокировки операций и для интенсивных вычислений вещей, это будет один поток на ядро, чтобы начать и настроить оттуда.

Удачи.

http://letitcrash.com/post/40755146949/tuning-dispatchers-in-akka-applications