Управление процессами

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

Глобальная переменная process всегда доступна.

Информация о процессе

Получить текущий frame ID или process ID:

local frame_id = process.id()  -- Идентификатор цепочки вызовов
local pid = process.pid()       -- ID процесса

Отправка сообщений

Отправить сообщение(я) процессу по PID или зарегистрированному имени:

local ok, err = process.send(destination, topic, ...)

Разрешение: process.send на целевой PID

Создание процессов

-- Базовый spawn
local pid, err = process.spawn(id, host, ...)

-- С мониторингом (получать события EXIT)
local pid, err = process.spawn_monitored(id, host, ...)

-- Со связыванием (получать LINK_DOWN при аварийном завершении)
local pid, err = process.spawn_linked(id, host, ...)

-- И связанный, и мониторящий
local pid, err = process.spawn_linked_monitored(id, host, ...)

Разрешения:

• process.spawn на id процесса
• process.host на id хоста
• process.spawn.monitored на id процесса (для вариантов с мониторингом)
• process.spawn.linked на id процесса (для связанных вариантов)

Управление процессами

-- Принудительно завершить процесс
local ok, err = process.terminate(destination)

-- Запросить корректную отмену с опциональным дедлайном
local ok, err = process.cancel(destination, "5s")

Разрешения: process.terminate, process.cancel на целевой PID

Мониторинг и связывание

Мониторинг или связывание с существующим процессом:

-- Мониторинг: получать события EXIT при завершении цели
local ok, err = process.monitor(destination)
local ok, err = process.unmonitor(destination)

-- Связывание: двунаправленное, получать LINK_DOWN при аварийном завершении
local ok, err = process.link(destination)
local ok, err = process.unlink(destination)

Разрешения: process.monitor, process.unmonitor, process.link, process.unlink на целевой PID

Опции процесса

local options = process.get_options()
local ok, err = process.set_options({trap_links = true})

Inbox и Events

Получить каналы для приёма сообщений и событий жизненного цикла:

local inbox = process.inbox()    -- Объекты Message из топика @inbox
local events = process.events()  -- События жизненного цикла из топика @events

Типы событий

Поля событий

Подписка на топики

Подписка на пользовательские топики:

local ch = process.listen(topic, options)
process.unlisten(ch)

Объекты Message

При получении из inbox или с {message = true}:

local msg = inbox:receive()

msg:topic()    -- string: имя топика
msg:from()     -- string|nil: PID отправителя
msg:payload()  -- any: данные payload

Синхронный вызов

Создать процесс, дождаться результата и вернуть:

local result, err = process.exec(id, host, ...)

Разрешения: process.exec на id процесса, process.host на id хоста

Обновление процесса

Обновить текущий процесс на новое определение с сохранением PID:

-- Обновить на новую версию, передать состояние
process.upgrade(id, ...)

-- Оставить то же определение, перезапустить с новым состоянием
process.upgrade(nil, preserved_state)

Контекстный Spawner

Создать spawner с пользовательским контекстом для дочерних процессов:

local spawner = process.with_context({request_id = "123"})

Разрешение: process.context на "context"

Методы SpawnBuilder

SpawnBuilder иммутабелен — каждый метод возвращает новый экземпляр:

spawner:with_context(values)      -- Добавить значения контекста
spawner:with_actor(actor)         -- Установить актора безопасности
spawner:with_scope(scope)         -- Установить область безопасности
spawner:with_name(name)           -- Установить имя процесса
spawner:with_message(topic, ...)  -- Поставить в очередь сообщение для отправки после spawn

Разрешение: process.security на "security" для :with_actor() и :with_scope()

Методы spawn у Spawner

spawner:spawn(id, host, ...)
spawner:spawn_monitored(id, host, ...)
spawner:spawn_linked(id, host, ...)
spawner:spawn_linked_monitored(id, host, ...)

Те же разрешения, что и у функций spawn на уровне модуля.

Реестр имён

Регистрация и поиск процессов по имени:

local ok, err = process.registry.register(name, pid)  -- pid по умолчанию текущий
local pid, err = process.registry.lookup(name)
local ok = process.registry.unregister(name)

Разрешения: process.registry.register, process.registry.unregister на имя

Разрешения

Разрешения контролируют, что вызывающий процесс может делать. Все проверки используют контекст безопасности (актор) вызывающего против целевого ресурса.

Вычисление политики

Политики могут разрешать/запрещать на основе:

• Actor: Принципал безопасности, делающий запрос
• Action: Выполняемая операция (например, process.send)
• Resource: Цель (PID, id процесса, id хоста или имя)
• Attributes: Дополнительный контекст, включая pid (ID процесса вызывающего)

Справочник разрешений

Множественные разрешения

Некоторые операции требуют нескольких разрешений:

Ошибки

См. Обработка ошибок для работы с ошибками.

См. также

• Каналы — межпроцессная коммуникация
• Очереди сообщений — сообщения через очереди
• Функции — вызов функций
• Супервизия — управление жизненным циклом процессов