Результаты поиска по запросу: *

Добавил ожидание завершиния отложеного вызова. При вызове метода send возвращается объект Callback, если через методы данного объекта, были установлены обработчик успешного и провального завершения вызова, или хотябы один обработчик, тогда актор блокирует и ожидает завершения. Все входящие...

Точка входа для любой модели: Model.launch(instance)

Продолжаем шаманизм, самая простая реализаци В данной реализации можнно: - создавать акторы, регистрировать объекты в системе Context.create(name, instance) - отправлять сообщения, вызывать отложенный метод Context.send(methodName, ...arguments) В один момент времени объект-актор, может...

Реализовал эксперементальную версию, где любой java объект может быть актором, поведение задается через публичные методы. Суть в том, что к каждому объекту может быть обработан только один вызов метода, в любой момент времени. Вызов метода, не ожидается, и результат не обрабатывается, на текущий...

Немного обновлю. Переписал "немного". Решил использовать ForkJoinPool, стандартную реализацию. Получается относительно не плохая производительность. Изменение в программировании поведения актора: - теперь актору отправляется в сообщении массив объектов, получается на подобии RPC. Пример...

Пришлось изучать фундаментальные труды, по альтернативами моделям, другие реализации(akka, killim, actor-foundary). Много времени уходит, пришел к более обобщенной модели. Обновил actor-model / actors — Bitbucket. Там можно посмотреть текущий прототип. Завтра выложу последний вариант. Я пытаюсь...

Ну она где-то так и есть. D java нету механизма pattern matching. Но в данном случае получается reactive парадигма. Программируемое поведение на лету. В scala бы этот участок был бы грациозней хД

Обновление. - Добавил актор-консоль. Через трейт actor.util.Consol.TConsole, добавляется метод, через который можно отправлять строку на консоль(println(Object)). - Добавил систему остановки акторов. При вызове метода stop, для актора, генерируется событие Event.Stop. При обработке его, актор...

Расширил управление поведением. Добавил: - возможность предиката (actor.samples.EvenAndOdd) - возможность задавать поведения, для определенных значения(actor.samples.ValuesCase) Добавил подержу синглтон акторов. Синглтон актор - актор, объект которого может находиться в одном экземпляре, в...

"Один актор не является актором. Актор является частью системы акторов" Рассмотри простой пример двух акторов. У нас, есть два актора Ping и Pong. Акторы, с задержкой в одну секунду, пересылаю друг другу сообщения. Актор Ping отправляет строку "ping" актору Pong. Получив строку, Pong отображает...

Продолжим. Реализовал систему с помощью обычной синхронизации, не блокирующие очереди оставил на потом. Реализовано все топорно, чтобы работал фундамент. На данный момент можно: - создавать актор - отправлять сообщение актору - делать запрос с ожиданием ответа к актору. Основные принципы...

Расширил функционал очереди. Добавил различные функции, которые учитывают указанную задержку, для обработки. Пробую алгоритм рекурсивных сообщений, в различных случаях позволяет добиться 15-20 миллионов сообщений в секунда, на 3000 акторов.(тест на счетчиках) Система с единичным акторов...

Обновления: Создал новую ветку. Пробую реализовать, другим способом: - уменьшилось количество этапов передачи сообщения(Сообщение передается на прямую без посредником, посредник только при отправке сообщения через не связанную ссылку) - удалось увеличить количество обрабатывающих сообщений на...

Долго мучаюсь, но вот уже созреваю до конечной программной концепции, своей реализации модели акторов. Для общего ознакомления рекомендую почитать статью на википедиии Модель акторов — Википедия Для полного ознакомления, рекомендую почитать: Нюансы моей реализации: - в системе есть...