OCaml中的并行编程：从线程到协程

open Fiber.O

(* 定义一个函数，用于创建一个HTTP客户端 *)
let create_client () =
  let open Cohttp_lwt_unix in
  let open Cohttp in
  let uri = Uri.of_string "http://www.baidu.com" in
  (* 创建一个请求 *)
  let request = Request.make ~meth:`GET uri in
  (* 设置亿牛云爬虫加强版代理IP和认证信息username、password *)
  let proxy = Some (Uri.of_string "http://www.16yun.cn:8080") in
  let auth = Some ("16YUN", "16IP") in
  (* 发送请求并获取响应 *)
  Client.request ~proxy ~auth request >>= fun (response, body) ->
  (* 打印响应的状态码和头部 *)
  Printf.printf "Status: %s\n" (Code.string_of_status response.status);
  Header.iter (fun k v -> Printf.printf "%s: %s\n" k (String.concat ", " v)) response.headers;
  (* 返回响应的正文 *)
  Body.to_string body

(* 定义一个函数，用于创建多个Fiber，并等待它们的结果 *)
let run_fibers n =
  (* 创建一个列表，包含n个Fiber *)
  let fibers = List.init n (fun _ -> Fiber.of_thunk create_client) in
  (* 并行地执行所有的Fiber，并返回一个列表，包含它们的结果 *)
  Fiber.parallel_map fibers ~f:(fun fiber -> fiber)

(* 定义一个主函数，用于运行Fiber，并打印结果 *)
let main () =
  (* 创建一个Fiber，用于运行4个Fiber，并等待它们的结果 *)
  let fiber = run_fibers 4 in
  (* 将Fiber转换为Lwt.t类型，并执行它 *)
  let lwt = Fiber.run fiber in
  (* 等待Lwt.t类型的值，并打印它 *)
  Lwt_main.run lwt |> List.iter print_endline

(* 调用主函数 *)
let () = main ()