問題タブ [system.threading.channels]
For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.
.net - 異なる TRead/TWrite で System.Threading.Channels を使用する
チャネルは、静的メソッドCreateUnbounded<TType>
またはを使用してインスタンス化されますCreateBounded<TType>
。作成されたチャネルは、書き込みを受け入れ、読み取りを発行しますTType
。
私のユースケースでは、書き込むTType
が放出するチャネルが必要ですobjects
。タイプがあるので、これは可能であるように見えますChannel<TWrite, TRead>
ので、本質的にはChannel<TWrite, object>
. このインスタンスを作成する方法はありますか? 以下のスクリーンショットを参照してください
c# - ChannelReader.WaitToReadAsync のときに InvalidOperationException がスローされないようにするにはどうすればよいですか?
System.Threading.Channels を使用して非同期キューを作成しました。しかし、テストのためにプログラムを実行すると、ランダムなタイミングで次の例外がスローされ、ワーカー スレッドが停止しました。
例外がキャッチされて無視された場合、コードは機能しています。でも、原因不明のエラーをなくしたい。
ここに私の環境と最小のコードがあります。
- TargetFramework = netcoreapp2.1
- System.Threading.Channels バージョン = 4.5.0