Zenject与UniRx结合实现跨线程通信Signal

   // 定义Signal
    public class TestCrossThreadCommEvent : Signal<string, TestCrossThreadCommEvent> { }

1   // Install Signals
2     Container.DeclareSignal<TestCrossThreadCommEvent>();

 1 // 启动线程
 2     tth = new Thread(() =>
 3     {
 4         while (true)
 5         {
 6             Thread.Sleep(1000);
 7             _crossThreadCommEvent.Fire("fire not in main thread");
 8             //_unityEvent.Invoke();
 9         }
10     });
11     tth.Start();
12     // UniRx
13     _crossThreadCommEvent.AsObservable.ObserveOnMainThread(MainThreadDispatchType.Update)
14         // 使用lambda表达式是没有问题的
15         .Subscribe(s => TestCrossThreadComm(s))
16         .AddTo(this);
17     
18     void TestCrossThreadComm(string msg)
19     {
20         Debug.Log(Thread.CurrentThread.ManagedThreadId);
21         Debug.Log(msg);
22         transform.RotateAround(transform.position, Vector3.up, 5f);
23     }