0
ответов

Реагировать на фьючерсы

Я пытаюсь использовать подход «разделяй и властвуй» (он же вилка / объединение) для решения проблемы вычисления чисел. Вот код: import scala.actors.Futures.future private def compute (input: Input): Result = {...
вопрос задан: 8 November 2011 04:22
0
ответов

Ожидает ли поток блока Scala Future?

Когда я жду результата Scala Future, он ведет себя больше как получение или как реакция, то есть блокирует поток или планирует продолжение после результата, если он доступен ?
вопрос задан: 8 November 2011 04:21
0
ответов

Преимущества актеров над фьючерсами

Я в настоящее время программирую в фьючерсы, и мне довольно любопытно, что такое актеры. Хотелось бы услышать опытный голос: Каковы преимущества актеров перед фьючерсами? Когда я должен использовать одного из них вместо ...
вопрос задан: 8 November 2011 04:17
0
ответов

Как написать актор таймера в Scala?

Мне нужно, чтобы актер отправлял сообщение каждую минуту. Как мне лучше всего добиться такого поведения? Я опасаюсь использовать java.lang.Thread.sleep (long millis), поскольку поток может совместно использоваться многими акторами в Scala, так как ...
вопрос задан: 7 November 2011 22:51
0
ответов

gc большего количества акторов scala

, если я хочу реализовать http-сервер. я создаю нового актера по запросу. Таким образом, он может увеличиваться по мере обновления моего процессора. но вызовет ли это проблемы с использованием памяти? Говорят, что у актера есть какие-то странные ...
вопрос задан: 3 November 2011 11:43
0
ответов

Что такое self в Akka?

Просто читая примеры Akka, не понимаете, как определяется self.reply? Насколько я понимаю, для ответа на сообщение внутри блоков приема используется самостоятельный ответ. Но что касается ответа, это метод ...
вопрос задан: 2 November 2011 21:47
0
ответов

Актеры (scala / akka): подразумевается, что доступ к методу приема будет осуществляться в потокобезопасном режиме ?

Я предполагаю, что сообщения будут приниматься и обрабатываться потокобезопасным способом. Тем не менее, я читал (некоторые) документы akka / scala, но я еще не встречал ключевое слово «threadsafe».
вопрос задан: 14 October 2011 19:42
0
ответов

зачем использовать обработчик событий akka для ведения журнала

В следующем документе описываются обработчики событий, которые заменяют ведение журнала http://akka.io/docs/akka/1.2/general/event- handler.html Существует обработчик событий, который заменяет ...
вопрос задан: 12 October 2011 16:27
0
ответов

Библиотеки распределенного параллелизма на основе акторов для Ocaml и других языков [закрыто]

Вопрос: Может ли кто-нибудь порекомендовать библиотеку для Ocaml, которая предлагает модель параллелизма на основе акторов для распределенных вычислений? Обратите внимание на «на основе актера» и «распределенный» - я бы хотел, чтобы на основе актера ...
вопрос задан: 27 September 2011 09:00
0
ответов

Scala, актеры, что происходит с непрочитанными сообщениями в папке?

Что происходит с непрочитанными сообщениями в папке в актерах Scala? Например, два случая: 1. Если забудьте реализовать реактивный случай для специального сообщения: Actor! NoreactCaseMessage2. Если сообщения становятся слишком быстро: (...
вопрос задан: 3 September 2011 02:11
0
ответов

Соответствует ли модель производителя / потребителя Актеру?

Итак, в последнее время я читал много статей о том, насколько сложно параллельное программирование и насколько практически невозможно параллельное программирование с общим состоянием. Итак, такие языки, как Erlang (я думаю, что это ...
вопрос задан: 9 August 2011 19:10
0
ответов

Использование Mokito чтобы имитировать объект журнала Akka Actor

Я пробовал несколько вещей, которые, кажется, компилируются, но выдают исключения NullPointer во время модульного тестирования, поэтому мне интересно, как я потенциально могу преодолеть ограничения в модульном тестировании. У меня есть ...
вопрос задан: 31 July 2011 10:18
0
ответов

Отправка сообщений функциям в Scala

Я прорабатываю Семь языков Брюса Тейта за семь недель, и мне трудно понять его реализацию sizer.scala (Scala: Day 3). В частности, подумайте о следующем ...
вопрос задан: 19 July 2011 07:23
0
ответов

как отменить ConsoleReader.readLine ()

в первую очередь, я изучаю scala и новичок в мире Java. Я хочу создать консоль и запустить эту консоль как службу, которую вы можете запускать и останавливать. Мне удалось запустить ConsoleReader в Actor ...
вопрос задан: 17 July 2011 09:53
0
ответов

Как предотвратить рост почтового ящика акторов в Scala?

Насколько я знаю, почтовые ящики акторов Scala не имеют ограничений по размеру. Итак, если актор читает сообщения из своего почтового ящика медленнее, чем другие отправляют сообщения в этот почтовый ящик, то он в конечном итоге создает ...
вопрос задан: 15 July 2011 14:39
0
ответов

Как изменить тайм-аут в составленных фьючерсах?

В примере из документации akka 1.1 по составлению фьючерсов мне интересно, как можно программно установить тайм-аут сгенерированного фьючерса. Я знаю, что могу настроить глобальные ...
вопрос задан: 13 July 2011 18:45
0
ответов

Можно ли использовать сообщения с блокирующими субъектами, если они упакованы в будущее?

Мое текущее приложение основано на akka 1.1. В нем есть несколько ProjectAnalysisActors, каждый из которых отвечает за выполнение аналитических задач для конкретного проекта. Анализ запускается, когда такой актер ...
вопрос задан: 13 July 2011 13:33
0
ответов

Как работает ввод-вывод в Akka?

Как работает модель актора (в Akka), когда вам нужно выполнить ввод-вывод (например, операцию с базой данных) ? Насколько я понимаю, операция блокировки вызовет исключение (и по существу разрушит все ...
вопрос задан: 30 June 2011 06:42
0
ответов

Выполнение задач, связанных с процессором, с помощью акторов Scala?

Предположим, мне нужно запустить несколько процессоров -связанные задачи. Если у меня, например, 4 процессора, я бы, вероятно, создал фиксированныйразмер пула потоков из 4-5 рабочих потоков, ожидающих в очереди и помещающих задачи в ...
вопрос задан: 24 June 2011 12:07
0
ответов

Что делает функция «eventloop» в Scala Actors ?

Что делает функция eventloop в Scala Actors и для чего она полезна?
вопрос задан: 16 June 2011 09:11
0
ответов

Должны ли сообщения акторов расширять общий признак?

В большинстве примеров правильного использования структур акторов scala (и akka) люди склонны выводить каждое сообщение из одного признака. Например: трейт Сообщение объект Ping расширяет сообщение object Pong ...
вопрос задан: 12 June 2011 14:20
0
ответов

Пример клиент-сервер с акторами Scala

Как лучше всего реализовать следующий пример? Сервер-исполнитель получает запросы, обрабатывает их, создает новый ответ для каждого запроса и отправляет ответ обратно отправителю запроса. ...
вопрос задан: 11 June 2011 17:23
0
ответов

Обнаружение сервера удаленного актора Akka

Я хотел бы развернуть программное обеспечение удаленных участников, созданное с помощью akka, в кластере. Система состоит из нескольких рабочих узлов и одного главного узла. Проблема в том, что я не могу заранее знать ...
вопрос задан: 10 June 2011 11:43
0
ответов

Последовательность доставки сообщений в акторах akka

Я новичок в Akka и не могу найти ответ в справочное руководство. Предположим, у нас есть удаленные акторы, распределенные в кластере из 3 машин (A, B, C), где по одному актеру живет на каждой машине ...
вопрос задан: 1 June 2011 13:09
0
ответов

Akka Актер не завершает работу, если возникает исключение

В настоящее время я пытаюсь начать работу с Akka, и у меня возникла странная проблема. У меня есть следующий код для моего Актера: class AkkaWorkerFT расширяет Actor {def receive = {case Work (n, c) if n ...
вопрос задан: 29 May 2011 20:25
0
ответов

Является ли создание нового субъекта из существующего потокобезопасным?

Как уже несколько раз говорилось здесь, вы можете запустить новый поток (поместить вычисление с длительной обработкой в ​​блок актора {}) внутри актора, и порожденные вычисления будут безопасно выполняться в том же самом ...
вопрос задан: 18 May 2011 11:49
0
ответов

Как мы тестируем Актеры в Java?

Единственное, что я видел до сих пор, это кто-то публикует пример тестирования TypedActor. Я так понимаю, что нет возможности протестировать UntypedActor через, скажем, Junit? Документация Akka становится лучше с каждым днем ​​...
вопрос задан: 11 May 2011 22:19
0
ответов

когда актер не подходит?

Я использую акторов всякий раз, когда мне нужно для одновременного запуска двух потоков. Я никогда не использую потоки явно. кто-то сказал мне, что актеры довольно тяжелые и использовать их не всегда хорошая идея. Что ...
вопрос задан: 3 May 2011 06:11
0
ответов

Как Объединить или пропустить повторяющиеся сообщения в Scala Actor?

Допустим, у вас есть компонент графического интерфейса, и все 10 потоков сообщают ему, что нужно перерисовывать одновременно, когда они все поступают, до того, как будет выполнена одна операция рисования. Вместо того, чтобы наивно тратить ...
вопрос задан: 2 May 2011 12:13
0
ответов

как очистить мой мертвый актер в Scala

Привет, я использую scala (2.8.1) для реализации трудоемкого обработчика задач с использованием актора, однако я не могу очистить он запускался при запуске моих модульных тестов, поэтому мои модульные тесты зависали навсегда. как я называю ...
вопрос задан: 30 April 2011 02:01