我正在尝试创建一个新线程,但其中的代码不起作用并且不会引发任何错误。
new Thread(() -> {
for(int i = 0; i < 10; i++){
try {
Thread.sleep(100);
}catch (InterruptedException e){
e.printStackTrace();
}
System.out.println("Thread " + i);
}
}).start();
当在 Observer 中触发 onNext() 方法时,我使用此线程。线程处理接收到的数据。告诉我,也许我什么都没做。已经很迷茫了。
问题解决了。我对Dmitry Erokhin和Arty Morris深表感谢。
代码已重写如下。
由于某种原因,该线程被称为守护线程。这已通过验证
然后,只需“手动”设置流类型
然后所有代码都可以正常工作。再次,非常感谢所有提供帮助的人。谢谢你。