スレッドなしの非同期/待機を理解する[複製]

MSDNによると、asyncそしてawait新しいスレッドを作成しないでください。

のasyncそしてawaitキーワードによって追加のスレッドが作成されることはありません。

これを念頭に置いて、私はいくつかの簡単なプログラムの制御フローを理解することが困難です。私の完全な例は以下の通りです。それが必要であることに注意してくださいデータフローライブラリこれはNuGetからインストールできます。

using System;
using System.Threading.Tasks.Dataflow;

namespace TaskSandbox
{
    class Program
    {
        static void Main(string[] args)
        {
            BufferBlock<int> bufferBlock = new BufferBlock<int>();

            Consume(bufferBlock);
            Produce(bufferBlock);

            Console.ReadLine();
        }

        static bool touched;
        static void Produce(ITargetBlock<int> target)
        {
            for (int i = 0; i < 5; i++)
            {
                Console.Error.WriteLine("Producing " + i);
                target.Post(i);
                Console.Error.WriteLine("Performing intensive computation");
                touched = false;
                for (int j = 0; j < 100000000; j++)
                    ;
                Console.Error.WriteLine("Finished intensive computation. Touched: " + touched);
            }

            target.Complete();
        }

        static async void Consume(ISourceBlock<int> source)
        {
            while (await source.OutputAvailableAsync())
            {
                touched = true;
                int received = source.Receive();
                Console.Error.WriteLine("Received " + received);
            }
        }
    }
}

出力：

Producing 0
Performing intensive computation
Received 0
Finished intensive computation. Touched: True
Producing 1
Performing intensive computation
Received 1
Finished intensive computation. Touched: True
Producing 2
Performing intensive computation
Received 2
Finished intensive computation. Touched: False
Producing 3
Performing intensive computation
Received 3
Finished intensive computation. Touched: False
Producing 4
Performing intensive computation
Received 4
Finished intensive computation. Touched: True

これはそれを示しているようですConsumeが制御されている間forループが実行されているOutputAvailableAsyncタスクは完了します。

for (int j = 0; j < 100000000; j++)
    ;

これはスレッドモデルでは当然のことです。追加のスレッドが関与していない場合は、Produce中央の歩留り管理forループ？

• @ I4V：その質問に対する答えは、「すべてのブロッキング操作がasync / awaitモデルを使用して明示的に制御を渡すことが必要である」と述べています。しかし私の質問では、コントロールはProduceにConsumeなしでProduce明示的に制御を譲ります。それは私が混乱している部分です。 - Matthew
• @ MatthewこれはコンソールアプリケーションなのでありませんSynchronizationContextつまり、からのすべてのコールバックがawait電話をするSynchronizationContext.Defaultこれはスレッドプールなので、技術的には実際にはこのプログラムの実行中に実行されている2つのスレッドがあります。追加のスレッドが作成されないようにするには、独自のカスタム同期コンテキストを作成して設定する必要があります。行った場合は、Recieved特にすべてのプロデュースが完了するまで呼び出しは呼び出されません。ではない生産しながら制御を生み出す。 - Servy
• @Servy：複数のスレッドが関与している場合、MSDNは「特に、競合状態を防ぐ必要がないため、IOに制限された操作に対してBackgroundWorkerよりも優れている」と主張しています。私は自分の例を編集して単純な競合条件を追加しました。 - Matthew
• @マシューawaitしていません必ずしもスレッドの作成を含みます。スレッドを作成しない方法で使用できます。あなたは単にそうしていないのです。また、コールバックを実行するためだけにスレッドプールthreadを使用していることにも注意してください。そのスレッドプールthreadはありませんブロッキング何もしない場合は、実際には何もしていないため、プールに解放されます。別のリクエストを処理することができます。これは重要なことです。100個のスレッドプールスレッドがそこにブロックされていてIOが完了するのを待っていないという意味です。 - Servy
• あなたは見つけるかもしれません俺のasync/awaitイントロ役に立った私は単一の記事で（すべての関連する詳細と共に）基本をカバーしようとしました。 - Stephen Cleary