F＃の非同期的なバリア

Question

私は、ディスク上のすべてのディレクトリを非同期的にリストするプログラムをF＃で作成しました。非同期タスクは、指定されたディレクトリ内のすべてのファイルをリストし、別々の非同期タスク（デーモン：Async.Startを使用して開始します）を作成してサブディレクトリを一覧表示します。彼らはすべて結果を中央のMailboxProcessorに伝えます。

私の問題は、どのようにすべてのデーモンタスクが完了し、それ以上のファイルが到着しないことを検出するのですか？基本的には、私のトップタスクの（直接的かつ間接的な）子どもであるすべてのタスクの障壁が必要です。私はF＃の非同期モデルでそれを見つけることができませんでした。

私が代わりに行ったことは、各タスクの開始と終了を登録する別のMailboxProcessorを作成することでした。アクティブカウントがゼロになると、私は完了です。しかし、私はその解決策に満足していません。その他の提案はありますか？

Answer 1

Async.Parallelを試しましたか？つまり、各サブディレクトリAsync.Startではなく、サブディレクトリタスクをAsync.Parallel経由で単一の非同期に結合するだけです。その後、あなたはRunSynchronouslyであることができる（入れ子にされた）fork-joinタスクで終わり、最終結果を待つ。ここで

EDIT

は要点を示し、いくつかのおおよそのコード、そうでない場合は、完全な詳細です：

open System.IO 

let agent = MailboxProcessor.Start(fun mbox -> 
    async { 
     while true do 
      let! msg = mbox.Receive() 
      printfn "%s" msg 
    }) 

let rec traverse dir = 
    async { 
     agent.Post(dir) 
     let subDirs = Directory.EnumerateDirectories(dir) 
     return! [for d in subDirs do yield traverse d] 
       |> Async.Parallel |> Async.Ignore 
    } 

traverse "d:\\" |> Async.RunSynchronously 
// now all will be traversed, 
// though Post-ed messages to agent may still be in flight 

EDIT 2

ここでの回答を使用して待機バージョンです：

open System.IO 

let agent = MailboxProcessor.Start(fun mbox -> 
    async { 
     while true do 
      let! dir, (replyChannel:AsyncReplyChannel<unit>) = mbox.Receive() 
      printfn "%s" dir 
      replyChannel.Reply() 
    }) 

let rec traverse dir = 
    async { 
     let r = agent.PostAndAsyncReply(fun replyChannel -> dir, replyChannel) 
     let subDirs = Directory.EnumerateDirectories(dir) 
     do! [for d in subDirs do yield traverse d] 
       |> Async.Parallel |> Async.Ignore 
     do! r // wait for Post to finish 
    } 

traverse "c:\\Projects\\" |> Async.RunSynchronously 
// now all will be traversed to completion 

Answer 2

タスクを開始/終了するときには、Interlockedを増減するだけで、ゼロになるとすべて完了します。私はMailboxProcessorsと同様のコードでこの戦略を使用しました。

Answer 3

Task.Factory.StartNew()と0123を使用するほうがよい場合があります。

Answer 4

これはおそらく学習の練習ですが、すべてのファイルの怠惰なリストに満足しているようです。それは価値がある何のため

​​

（と私はこのようなものはF＃のが、私は自宅で私と一緒に持っていない書籍、の全てであると思います）...上記ブライアンの答えから盗む、私が発見しましたF＃での非同期ワークフローは、一般的なマルチタスキングはあまり試していませんが、 "困惑しやすい"並列問題に非常に役立ちます。

Answer 5

ちょうど解明のために：私は、チャペルでできることに似たよりよい解決策があるかもしれないと思った。そこには、 "同期"ステートメントがあります。これは、ステートメント内で生成されたすべてのタスクが完了するのを待つバリアです。ここでチャペルのマニュアルからの例です：

def concurrentUpdate(tree: Tree) { 
    if requiresUpdate(tree) then 
     begin update(tree); 
    if !tree.isLeaf { 
     concurrentUpdate(tree.left); 
     concurrentUpdate(tree.right); 
    } 
} 
sync concurrentUpdate(tree); 

「開始」文はAsync.StartとF＃の「非同期」ブロックと少し似て並列に実行されるタスクを作成します。