Результаты поиска по запросу "akka"
Нужно ли мне повторно использовать ту же Akka ActorSystem или я могу просто создать ее каждый раз, когда она мне понадобится?
Akka 2.x требует много команд для ссылки наActorSystem, Итак, чтобы создать экземпляр актераMyActor Вы могли бы сказать: val system = ActorSystem() val myActor = system.actorOf(Props[MyActor])Из-за частой необходимостиActorSystem: многие примеры ...
Инкрементная обработка в актере akka
У меня есть актеры, которые должны выполнять очень длительную и дорогостоящую работу, но само вычисление может выполняться постепенно. Таким образом, хотя самому полному вычислению требуются часы, промежуточные результаты на самом ...
распространение приложения с микроядром akka вместе с maven
У меня есть приложение с микроядром akka, разработанное в Java. Чтобы распространять приложение, я использовал учебники в блоге JCrankyi http://jcranky.com/2012/07/13/akka-microkernel-with-maven/#comment-1322используя maven-assembly-plugin и ...
Пример Java для отправки неблокирующего http-запроса от AKKA
В документации АККА написано, что ... Актеры не должны блокировать (то есть пассивно ждать, занимая поток) на некотором внешнем объекте, который может быть блокировкой, сетевым сокетом и т. Д. Операции блокировки должны выполняться в каком-то ...
Akka - повторная отправка сообщения «взлом»
В официальномАкка 2.0.4 документы [http://doc.akka.io/docs/akka/2.0.4/scala/actors.html#Restart_Hooks]это говорит: Перезапуск актера заменяет только фактический объект актера; перезапуск не затрагивает содержимое почтового ящика, поэтому ...
Конфигурация потоков на основе нет. процессорных ядер
Сценарий: у меня есть пример приложения, и у меня есть 3 различных конфигурации системы - - 2 core processor, 2 GB RAM, 60 GB HHD, - 4 core processor, 4 GB RAM, 80 GB HHD, - 8 core processor, 8 GB RAM, 120 GB HHDЧтобы эффективно ...
Акка Килл против Стоп против Яда Таблетки?
Вопрос новичка об Akka - я читаю над Akka Essentials, может, кто-нибудь объяснит разницу между Akka Stop / Poison Pill и Kill? Книга предлагает лишь небольшое объяснение: «Убить синхронно, а отравляющая таблетка асинхронна». Но каким образом? ...
преобразование будущего Akka [A] в будущее [либо [исключение, A]]
Есть ли метод в Akka (или в стандартной библиотеке в Scala 2.10) для преобразованияFuture[A] который может потерпеть неудачу вFuture[Either[Exception,A]]? Я знаю что ты можешь написать f.map(Right(_)).recover { case e:Exception => Left(e) ...
Как я могу получить абсолютный удаленный URL-адрес актера изнутри актера?
Я хочу сделать что-то подобное. Актер А: actorB ! "info" def receive()={ case _ => { println("Remote address is "+ _) } } Актер Б: (это развернуто удаленно) def receive()={ case "info" => { sender tell self.path.address.toString } }Я хочу, ...
странное сообщение об ошибке: неверная символическая ссылка. Подпись в package.class ссылается на термин apache в пакете org, который недоступен
Когда я пытался скомпилировать простую типизированную программу akka (scala 2.10, akka, 2.1.0): scalac -cp "akka-actor_2.10-2.1.0.jar:akka-camel_2.10-2.1.0.jar" write2.scala error: bad symbolic reference. A signature in package.class refers to ...