Как отправить события WebSocket из операции блокировки? (Требуется консультация по дизайну)

Question

Я использую Mojolicious WebSocket для установления протокола обмена сообщениями между сервером и клиентом.

На сервере существует долговременная работа, и я хочу обновить его прогресс на стороне клиента.

В нескольких точках на стороне сервера код, который я называю $web_socket->send(...) и обработать его на стороне клиента ws.onmessage = function (event) {...};

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

Серверный логика:

some_computation1(); 
$web_socket->send('computation1 end'); 
... 
some_computation15(); 
$web_socket->send('computation15 end'); 
... 
some_computation100(); 
$web_socket->send('computation100 end. All ok!'); 

стороне клиента:

ws = new WebSocket(url); 
ws.onmessage = function (event) { 
    $('#log_view').append('<p>' + event.data + '</p>'); 
}; 
ws.onopen = function (event) { 
    ... 
}; 
ws.onclose = function (event) { 
    ... 
}; 

Answer 1

Я нашел, что это работает для меня: Mojo :: IOLoop-> one_tick;

some_computation1(); 
$web_socket->send('computation1 end'); 
Mojo::IOLoop->one_tick; 

UPD: или может быть это будет лучше, чтобы отделить длительную работу в фоновом потоке («вилку» или «задержки»).

Answer 2

There is два примера, как сделать это с помощью одного из двух модулей:

1. Mojo::IOLoop::ReadWriteFork
2. Mojo::IOLoop::ForkCall

Чтобы запустить его выполнить команду:
perl perl_ws_long_blocking_operation.pl daemon

U pd,. Если у вас есть много операций долго блокировки вы должны использовать Mojo::IOLoop::Delay:

Example of many long blocking operation

Чтобы запустить его выполнить команду:

morbo perl_ws_many_long_blocking_operations.pl