3

我正在尝试使用 Lwt 编写终端应用程序。基本上只要我的应用程序正在运行，我就需要使用 Lwt_io.read_line 观察终端的输入。

在我的程序运行时，是否有比以下（伪代码）更好的方法来实现某种循环？

while true do
  let _ = ignore (Lwt_main.run my_application)
done

我不确定这是否是正确的方法。每次来自 my_application 的所有线程都完成时， Lwt_main.run 会再次被调用一次又一次......

Lwt 是否有其他或更好的方法来处理这个问题？

4

1 回答 1

4

您通常会将主循环编写为递归函数，该函数计算为一个线程，然后将该线程一次传递给Lwt_main.run. 这是一个小例子：

let () =
  let rec echo_loop () =
    let%lwt line = Lwt_io.(read_line stdin) in
    if line = "exit" then
      Lwt.return_unit
    else
      let%lwt () = Lwt_io.(write_line stdout line) in
      echo_loop ()
  in

  Lwt_main.run (echo_loop ())

这可以编译和运行：

ocamlfind opt -linkpkg -package lwt.unix -package lwt.ppx code.ml && ./a.out

粗略地说，这就是上面代码中发生的情况：

  1. echo_loop ()应用于 的论点Lwt_main.run。这立即开始评估Lwt_io.(read_line stdin)，但其余代码（从if表达式开始）被放入一个闭包中，以便在read_line完成后运行。echo_loop ()然后评估这种正在进行的read_line操作的组合，然后是关闭。
  2. Lwt_main.run强制您的过程等到所有这些完成。但是，一旦read_line完成，如果该行不是exit，则闭包触发一个write_line操作，然后是另一个闭包，该闭包echo_loop ()递归调用，然后启动另一个read_line，并且可以无限期地继续。
于 2016-11-19T16:43:20.780 回答