在F＃F＃連續循環

Question

我有一個需要在一個循環接受客戶端運行的套接字服務器，所以我發現，在funcional編程，遞歸循環使用：

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() 

而且此代碼調用通過這樣做：

Async.Start <| awaitConnections listener 

考慮到應用程序連續運行，我應該使用迭代方法嗎？ rec方法是否創建嵌套執行堆棧？

另外，我想循環結束後做一些事情，如：

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 

但後來它不能編譯，因爲awaitConnections返回類型。我怎麼能這樣做？我做對了嗎？

Answer 1

你當然是在正確的軌道上！下面是一個簡單的例子，說明了你需要做什麼：

// 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() 

幾個重點：

• 一個無限循環結束後，將無法真正運行的代碼（它是無限的！），但你可以使用try .. finally在塊取消時運行一些代碼

• 請注意，使用return!進行遞歸循環更好 - 使用do!會造成內存泄漏。

• 您可以使用取消令牌取消計算 - 只需在啓動時傳遞令牌即可。