非同期ソケットの読み込み：開始スレッドは終了してはいけません。

Question

私は（/待つ非同期を使用して）非同期で読み取るNetworkStreamを有する

await Task<int>.Factory.FromAsync((cb, state) => stream.BeginRead(buffer, offset, readLen - offset), stream.EndRead, null); 

残念ながら、IO例外が時々発生：「I/O動作があるため、スレッドの終了またはアプリケーションの要求によって中止されています"

Socke.EndReceive：http://msdn.microsoft.com/en-us/library/w7wtt64b.aspxに記載されている要件を満たしていると思います。

特定のスレッドによって開始されたすべての入出力は、そのスレッド が終了すると取り消されます。処理が完了する前にスレッドが を終了すると、保留中の非同期操作が失敗する可能性があります。

asyncメソッドはデフォルトスケジューラで実行されるため、この要件は保証されません。

方法はありますか？ I/Oを開始するために専用のスレッドを開始する必要がありますか？

よろしく、ディルク

Answer 1

私はparallelextensionsフォーラムに同じ質問をしています

http://social.msdn.microsoft.com/Forums/en-US/parallelextensions/thread/d116f7b0-c8ee-4ce4-a9b8-4c38120e45a4

基本的には、ThreadPoolのは、/ O保留中の非同期Iを持っている任意のスレッドを停止しません。したがって、ThreadPoolでソケット操作を開始する限り、この問題は発生しません。

Answer 2

あなたは本の中で最古のトリックを使用することができます。あなたのスレッドは決して終わりのないループで眠れないようにしてください。

while(true) { 
    Threading.Sleep(TimeSpan.FromSeconds(1); 
} 

私は上記のコードを私の頭から書いています。私は現在Macで作業しているので、Visual Studioでチェックしなかった。

スレッドを終了するには何かを書く必要がありますが、それはアプリケーションの流れに依存します。

Answer 3

終了しない専用I/Oスレッドを使用することをお勧めします。これが現実世界のコードの多くです。

スレッドループをGetQueuedCompletionStatusにするのが最も良い方法の1つです。 I/Oスレッドの1つにI/O操作を実行させる必要がある場合は、PostQueuedCompletionStatusまたはQueueUserAPCのいずれかを呼び出して、I/Oスレッドが操作をポストするようにします。

注意：これらの操作が失敗するケースを処理する必要があります。たとえば、あまりにも多くのAPCがすでにキューに入れられている場合は、QueueUserAPCが失敗する可能性があります。