修复多线程和observable的兼容问题
Fix compatibility issues between multithreading and observables
Optimization and multithreading written by n1luik