F # vòng lặp liên tục trong F #

Question

Tôi có một máy chủ socket mà cần phải chạy trên một vòng lặp chấp nhận khách hàng, vì vậy tôi phát hiện ra rằng trong chương trình funcional, một vòng lặp đệ quy được sử dụng:

let awaitConnections (wsl:WebSocketListener) = 
    let rec loop()= 
     async { 
      let! ws = Async.AwaitTask (wsl.AcceptWebSocketAsync(cancellation.Token)) 
      printfn "Connection from %s" (ws.RemoteEndpoint.Address.ToString()) 
      Async.Start <| awaitMessages ws 
      do! loop()} 
    loop() 

Và mã này được gọi bằng cách thực hiện:

Async.Start <| awaitConnections listener 

Xem xét ứng dụng chạy liên tục, tôi có nên sử dụng phương pháp lặp lại thay thế không? Phương pháp rec có tạo ngăn xếp thực thi lồng nhau không?

Ngoài ra, tôi muốn làm điều gì đó sau khi vòng lặp kết thúc, như:

let awaitConnections (wsl:WebSocketListener) = 
    let rec loop()= 
     async { 
      let! ws = Async.AwaitTask (wsl.AcceptWebSocketAsync(cancellation.Token)) 
      printfn "Connection from %s" (ws.RemoteEndpoint.Address.ToString()) 
      Async.Start <| awaitMessages ws 
      do! loop()} 
    loop() 
    printf "The loop ended" // <-- this line 

Nhưng sau đó nó không thể biên dịch bởi vì các loại awaitConnections trở lại. Làm thế nào tôi có thể làm điều đó? Tôi làm đúng chứ hả?

Answer 1

Bạn chắc chắn đang đi đúng hướng! Dưới đây là một ví dụ đơn giản thể hiện những gì bạn cần làm:

// Loop that keeps running forever until an exception happens 
let rec loop() = async { 
    do! Async.Sleep(1000) 
    printfn "Working" 
    return! loop() } 

// Call the loop in a try .. finally block to run some cleanup code at the end 
let main() = async { 
    try 
    do! loop() 
    finally 
    printfn "That's it!" } 

// Start the work in the background and create a cancellation token 
let cts = new System.Threading.CancellationTokenSource() 
Async.Start(main(), cts.Token) 
// To cancel it, just call: cts.Cancel() 

Một vài điểm quan trọng:

• Bạn có thể không thực sự chạy mã sau một kết thúc vòng lặp vô hạn (nó là vô hạn!) Nhưng bạn có thể sử dụng try .. finally để chạy một số mã khi khối bị hủy

• Lưu ý rằng việc sử dụng return! để lặp lại đệ quy tốt hơn - sử dụng do! tạo rò rỉ bộ nhớ.

• Bạn có thể hủy tính toán bằng mã thông báo hủy - chỉ cần chuyển mã thông báo khi bắt đầu.