Т
Тут остаётся сделать так, как предлагает Олег, чтобы это первое всё
Size: a a a
2021 June 26
Т
Вот процесс можно прервать, там есть метод kill, а поток нельзя
И
Ну если это в вайбе то у него должен быть хэндлер на обработку сигнала
EP
да сам вайб должен давать возможность остановить
И
Он может дават возможность завершить event loop снаружи
Т
Вот примерно такой код: https://vibed.org/api/vibe.http.websockets/WebSocket
Т
Висит в этом месте: auto txt = ws.receiveText;
EP
при завершении эвент лупа и должен из ожидания приёма сокет выйти
И
И даже из задачи и треда
И
Ну завтсит от того как запущено
Т
Ну вон в коде выше, который я привёл, там нет евент лупа, там цикл пока есть соединение и функция ожидания приёма сообщения, которая висит некоторое время
Т
Вот в arsd есть евент луп и есть функция его закрытия
EP
ну мб можно как-то по-другому это написать, либо библиотека сама по себе не предоставляет нужных возможностей, можно поискать другие
И
Как видно что именно в жтом месте висит
Т
Я думаю переделать на arsd и если там реализовать в ручном режиме, без евент лупа, то там тоже код более правильно выглядит:
Т
try_to_process_more:
while(ws.isMessageBuffered()) {
auto msg = ws.waitForNextMessage();
// process msg
}
if(ws.isDataPending()) {
ws.lowLevelReceive();
goto try_to_process_more;
} else {
// nothing ready, you can do other things
// or at least sleep a while before trying
// to process more.
if(ws.readyState == WebSocket.OPEN) {
Thread.sleep(1.seconds);
goto try_to_process_more;
}
}
while(ws.isMessageBuffered()) {
auto msg = ws.waitForNextMessage();
// process msg
}
if(ws.isDataPending()) {
ws.lowLevelReceive();
goto try_to_process_more;
} else {
// nothing ready, you can do other things
// or at least sleep a while before trying
// to process more.
if(ws.readyState == WebSocket.OPEN) {
Thread.sleep(1.seconds);
goto try_to_process_more;
}
}
Т
Смотрите, тут не висит на функции приёма сообщения, а проверяет есть ли данные в буфере, если они есть, то просто считывает их
Т
А значит и выход из этого цикла должен произойти более быстро
EP
это из доки пример?