Daniel T.
2020-12-03 10:24:36
使用此代码首先要了解的是，subscribeOn确定 Observable 事件的事件生成器将在哪个线程上调用，而不是值将在哪个线程上发出。如果源Observable在与其订阅的同一线程上发出，则你的代码将正常工作（例如，如果你使用Observable.just(_:)。但在主线程上modelSelected 发出该信号，而不管其订阅的线程是什么。flatMap运算符在其上调用其闭包）。它的源发出的线程，因此它也在主线程上。
所有这些的结果是，调用几乎没有用subscribeOn(_:)。它唯一实际执行预期操作的时间是，如果最终的源（最上游的）是Observable的生成器是同步的，阻塞的函数。（情况并非如此tableView.rx.modelSelected(String.self)）
在这种情况下，你想要的更像是：
tableView.rx.modelSelected(String.self)
.observeOn(ConcurrentDispatchQueueScheduler(qos: .background))
.flatMap { item -> Observable<String> in
sleep(3)
return Observable.just("Hello world!")
}
.retry()
.observeOn(MainScheduler.instance)
.subscribe(onNext: { value in
print(value)
})
.disposed(by: bag)
热门帖子
热门github
1
2
3
5
6
7
8
11
13
14
15
Mamba is a new state space model architecture showing promising performance on information-dense data such as language modeling, where previous subquadratic models fall short of Transformers. It is based on the line of progress on structured state space models, with an efficient hardware-aware design and implementation in the spirit of FlashAttention.
(翻译：Mamba 是一种新的状态空间模型架构，在信息密集型数据（例如语言建模）上显示出良好的性能，而之前的二次模型在 Transformers 方面存在不足。它基于结构化状态空间模型的进展，并本着FlashAttention的精神进行高效的硬件感知设计和实现。)
非常感谢您的友好解释。一切都像上面的代码中一样工作。