Странное поведение OCaml flush (выход из всех потоков)

Я пытаюсь реализовать CLI с двумя командами:

run, который порождает сокет unix в /my/path/file.sock и производит вывод
watch который подключается к сокету и перенаправляет вывод на свой собственный вывод

Когда я убиваю команду watch, я не могу понять, почему команда run тоже уничтожается. Они не вызывают никаких исключений или системных сигналов. Я заметил, что проблемы возникают из-за функции flush. После вызова он действует как exit 0. Почему?

Вот исходники: https://github.com/soywod/comodoro

sockets ocaml channel

13.12.2020 02:16

Стоит ли изучать PHP в 2023-2024 годах?

Привет всем, сегодня я хочу высказать свои соображения по поводу вопроса, который я уже много раз получал в своем сообществе: "Стоит ли изучать PHP в...

Поведение ключевого слова "this" в стрелочной функции в сравнении с нормальной функцией

В JavaScript одним из самых запутанных понятий является поведение ключевого слова "this" в стрелочной и обычной функциях.

Приемы CSS-макетирования - floats и Flexbox

Здравствуйте, друзья-студенты! Готовы совершенствовать свои навыки веб-дизайна? Сегодня в нашем путешествии мы рассмотрим приемы CSS-верстки - в...

Тестирование функциональных ngrx-эффектов в Angular 16 с помощью Jest

В системе управления состояниями ngrx, совместимой с Angular 16, появились функциональные эффекты. Это здорово и делает код определенно легче для...

Концепция локализации и ее применение в приложениях React ⚡️

Локализация - это процесс адаптации приложения к различным языкам и культурным требованиям. Это позволяет пользователям получить опыт, соответствующий...

Пользовательский скаляр GraphQL

Листовые узлы системы типов GraphQL называются скалярами. Достигнув скалярного типа, невозможно спуститься дальше по иерархии типов. Скалярный тип...

Перейти к ответу Данный вопрос помечен как решенный

Ответы 1

Ответ принят как подходящий

Сервер должен прослушивать отключение клиента и удалять соединение из списка подключений. Что-то вроде этого может сработать:

let client_thread conn =
  let in_ch = in_channel_of_descr conn in
  while true do
    try input_line in_ch |> ignore
    with End_of_file ->
     (* Remove conn from !conn and close the conn *)
  done
in

let add_conn () =
  (* ... *)
  Thread.create client_thread conn |> ignore;
  (* ... *)
in

Действительно, я не хотел слушать входящий канал, потому что мне это не нужно, но на самом деле знать, когда клиент отключается, необходимо. Теперь работает как шарм, спасибо!

— 13.12.2020 12:17

13.12.2020 12:01