Async Queue Processing With Reactive Extensions

Kunama-athikili ambalwa kulokhu, futhi lokhu ngiyakusebenza ... kepha ngifuna ukwazi ukuthi ngingayisetha kanjani inombolo enkulu yemicu Yomsebenzi yokubhaliselwe kwami ​​Okubonakalayo ngasikhathi sinye. [

Nginakho okulandelayo ukufanisa ukulondolozwa kwe-async kokufakiwe kwelog:

private BlockingCollection<ILogEntry> logEntryQueue;

kanye

 logEntryQueue = new BlockingCollection<ILogEntry>();
 logEntryQueue.GetConsumingEnumerable().ToObservable(Scheduler.TaskPool).Subscribe(SaveLogEntry);

Ukuhlelela ukulondolozwa kwami ​​... kepha ngiyicacisa kanjani imicu emikhulu yokusetshenziswa kwashejuli ngasikhathi sinye?