對於非線程安全類

Question

我有一個類來創建一個可觀察的包裝，

public class Test 
{ 
    public int Calc(); 
} 

這要求在同一個線程上測試創建一個上執行Calc的所有呼叫。我需要創建一次測試（昂貴的操作），並多次調用Calc。

我想有一個包裝，將讓我asynchronousely調用計算：

public class TestWrapper 
{ 
    private Test _test; 
    public IObservable<int> Calc(); 
} 

一種方式做到這一點是創建一個BackgroundWorker或線程，並用它作爲保證所有操作在測試上是在同一個線程上。爲了簡單起見，我們可以假設所有對Calc（）的調用都將按順序執行，所以不必擔心排隊。

有沒有更優雅的RX方式來做到這一點？

Answer 1

如果這是可能的，當創建TestWrapperTest要創建那麼這個類似乎滿足您的要求：

public class TestWrapper 
{ 
    public TestWrapper(Func<Test> factory) 
    { 
     _scheduler = new EventLoopScheduler(); 
     _test = Observable.Start(factory, _scheduler).First(); 
    } 

    private readonly EventLoopScheduler _scheduler; 
    private readonly Test _test; 

    public IObservable<int> Calc() 
    { 
     return Observable.Start(() => _test.Calc(), _scheduler); 
    } 
} 

它用於像這樣：

var testWrapper = new TestWrapper(() => new Test()); 
testWrapper.Calc().Subscribe(x => { }); 

我已經對它進行了測試，並在執行Calc的同一線程上創建了Test。另一方面，訂閱在與創建本身（即調用線程）上的testWrapper相同的線程上處理。

Answer 2

創建的Test實例時使用ThreadLocal<T>類：

var MyTEST = new ThreadLocal<Test>(); 

那麼你可以使用MyTEST.Value.Calc()的任何電話......

另一種選擇是使用把[ThreadStatic]的測試部件包裝類... 請參閱http://msdn.microsoft.com/en-us/library/system.threadstaticattribute.aspx

取決於您是否需要多個實例Test你可以使它成爲Singleton。

Answer 3

因此，從評論和重新讀你的問題我收集你想反覆調用Calc（）在一個恆定的線程，並有返回結果可用IObservable<Int>()？

在這種情況下，我會使用Observable.Create來包裝Test類和EventLoopScheduler以確保Calc的調用位於單個線程上。

public class TestWrapper 
{ 
    private Test _test; 
    public IObservable<int> Calc() 
    { 
    return Observable.Create(obsvr => 
    { 
     var fixedThreadsched = new EventLoopScheduler(); 
     var disp = new BooleanDisposable(); 
     while (!disp.IsDisposed) 
     { 
      fixedThreadsched.Schedule(() => obsvr.OnNext(_test.Calc())); 
     } 

     return disp; 
    }); 
    } 
}