为什么这个订阅阻塞了主线程？

文章/答案/技术大牛

发布

1回答

ruby、reactive

下面的代码“起作用”，从套接字接收的数据是流式的，即当新数据到达时，我会收到"data =“消息，但订阅会阻塞。如果我在subscription =语句后面添加任何代码，它直到我关闭套接字时才会执行。

浏览 22提问于2017-08-24得票数 0

回答已采纳

1回答

C#处理主UI线程的多个事件

c#、multithreading、winforms、event-handling、eventhandler

我有一组对象，它们在自己的线程(后台工作线程)中定期更新。我的主窗体从所有这些对象订阅一个ValueChanged事件，并相应地更新一些UI元素。myObjctList ) myObj.Refresh()///// This raises an event if data changed 如果myObj引发and事件，并且必须等到主UI订阅者完成后才能继续执行Refresh()的下一次迭代，此线程是

浏览 2提问于2015-01-30得票数 0

1回答

在WebFlux中生成UUID

java、multithreading、spring-webflux、project-reactor

o).getId() == null) { } }- locked <0x0000000600c4b510> (a io.netty.channel.nio.SelectedSelectionKeySet) - locked <0x0000000600c4b4b0> (a sun.nio.ch.KQue

浏览 2提问于2021-10-28得票数 1

回答已采纳

1回答

何时在blockingSubscribe中使用RxJava

rx-java、rx-java2

Observable.just(1, 2, 3, 4, 5)如果更改为以下内容，它不会打印结果，但为什么会这样呢TimeUnit.MILLISECONDS)我读到"blockingSubscribe“是为了阻止主线程，但是为什么一个线程会阻塞</

浏览 3提问于2020-06-10得票数 0

回答已采纳

1回答

另一个窗口处于活动状态时的WPF ShowDialog

c#、wpf、windows

当主窗口和倒计时窗口都显示时，用户可以单击一个按钮来启动带有ShowDialog的第三模态窗口。从单独的进程或单独的线程启动对话框窗口可以解决此问题吗？

浏览 1提问于2019-03-13得票数 0

1回答

后台慢速查询

android、performance、rx-java2、android-room

例如，我有两个相同的查询，一个在UI线程上运行，另一个返回一个Single。我正在使用allowMainThreadQueries()来测试这个案例。

浏览 0提问于2018-05-23得票数 4

回答已采纳

2回答

如何创建独立于Django服务器的kafka使用者

python、django、multithreading、apache-kafka

因此，一旦在kafka broker上创建了一个主题，我就指定一个使用者来订阅这个过程，为了实现这个非阻塞，我使用了multiprocessing模块，这样使用者就可以在一个单独的线程上运行，而不是阻塞主应用程序线程但是，我不确定，如果我的服务器关闭了，会发生什么？即使服务器没有运行，进程是否仍然像cron作业一样运行呢？如果不是，请有人建议我如何触发我的使用者，使它独立于我的django服务器？

浏览 0提问于2019-04-21得票数 1

1回答

RxJava android - does观察者块

android、observer-pattern、rx-java

给定这个简单的观察者和订阅者组合，它只是观察一个文件IO，然后根据值在订阅服务器中更新： } 我的问题是，在写完之前，观察者是否会阻塞即使我指定了另一个线程(IO

浏览 1提问于2015-01-21得票数 1

回答已采纳

1回答

如何在Faye中实现业务逻辑？Rails

ruby-on-rails、ruby、rack、faye

我在瘦服务器上有Rack Faye应用程序，并且我在每个faye客户端握手/订阅/断开连接上都有一些逻辑。这个逻辑需要在DB中存储数据，进行一些计算，并将消息发布回一些通道。应该在哪里以及如何实现这样的东西，以避免阻塞带有扩展的主Faye线程？

浏览 1提问于2012-08-23得票数 0

1回答

阻塞生成器似乎只为一个值生成。为什么？

python、multithreading

loop.create_task(subscribe(subscription))因此，SUBSCRIPTION_TYPES是一个由3个订阅组成的数组但是，这只为单个订阅生成流消息，而我似乎从未为任何其他订阅生成消息……它似乎在单个线程上阻塞。但它确实会生成多条消息，但只针对单个订阅。为什么会这样呢？我想发电机阻塞了..。但我不知道为什么。

浏览 5提问于2019-08-06得票数 1

1回答

RxJava:从多个观察者观察单个执行

android、rx-java、rx-android

因为我的应用程序有多个入口点(一个Activity，一个SyncAdapter)，所以我只想在我的Application类中做一次这个配置，并在入口点(Activity，SyncAdapter)上观察它但是，如果SyncAdapter中的观察者在Observable完成工作后连接，它就会永远阻塞。我遗漏了什么？是否有一种更惯用的方法来解决这个问题，例如使用Completable

浏览 3提问于2016-10-27得票数 0

1回答

如何在不阻塞主窗体的情况下创建对话框？

c++、qt、qtwidgets

on_actionPATH_triggered() { win->exec();我是否应该在单独的线程中使用async / run来避免阻塞主窗口，或者是否有方法可以订阅关闭甚至删除/空闲对象？

浏览 1提问于2014-12-08得票数 2

回答已采纳

1回答

为什么这个守护进程线程被阻塞了？

python-2.7、subprocess、python-multithreading

为什么cc.start()上有下面的代码块？crawler.py包含类似于的代码。

浏览 1提问于2016-03-11得票数 0

回答已采纳

1回答

Python线程事件

python、multithreading

我有一个线程，在那里我使用一个线程事件从目标函数外部控制线程。每当我想要返回线程时，在我的主函数中，我说的是flag.set()。然后将flag设置为true，我的目标函数完成执行，线程也完成。现在，如果我想在main函数中使用flag.wait(timeout = 5)，我希望阻塞并等待5秒来执行代码的“执行某件事”部分。然而，我看到代码中的“做点什么”部分像往常一样每隔0.5秒执行一次，我的main函数被阻塞了5秒。等待方法必须

浏览 0提问于2016-11-10得票数 1

1回答

Project Reactor -在并行调度程序上订阅不起作用

kotlin、project-reactor、reactive-streams

我正在查看示例和阅读文档，在尝试以并行方式订阅Flux时，我发现了一些问题。我有3个函数，如下所示。如果是这样，为什么会发生这种情况？

浏览 4提问于2018-08-18得票数 0

回答已采纳

2回答

从用户界面线程显示窗口有时会阻塞主用户界面线程。

c++、multithreading、mfc

我不是MFC专家，也肯定不是多线程专家，但我仍然想了解这种奇怪的行为。在某些地方，当我在我的应用程序中创建一个MFC ui线程时，它会被启动，并且可以显示一个消息框--没有问题，主ui线程被阻塞了。但是，有时如果我创建线程，那么线程执行就会停止，直到主ui线程再次不阻塞为止。当然，情况是编造出来的。主ui线程的阻塞表示某种形式的同步，而ui<e

浏览 8提问于2014-05-06得票数 2

回答已采纳

2回答

如果子线程主持IE控件，则子线程的阻塞会使主线程阻塞

c++、internet-explorer

情况是这样的：主线程创建一个子窗口。子线程创建IE控件。子线程将IE控件附加到子窗口。问题是，一旦子线程阻塞(例如::Sleep(10 * 1000 ) )，主线程的GetMessage函数就无法再获取消息，这意味着主线程也被阻塞了！我还是不明白。为什么子线程会影响主线程

浏览 1提问于2013-07-12得票数 0

4回答

TableView scrollToRow阻塞了主ui线程

ios、swift、uitableview

当我调用tableView.scrollToRow(at: indexPath, at: .bottom, animated: false)时，主UI线程被阻塞了3秒。有办法解决这个问题吗？

浏览 0提问于2017-02-23得票数 1

回答已采纳

3回答

从正确的线程调用RxJava2可取消/一次性

android、kotlin、rx-java、rx-java2

问题是，这个资源真的不喜欢从创建它的另一个线程中关闭(它杀死了一只小狗，并在发生这种情况时抛出一个异常)。当我释放订阅时，资源Cancellable/Disposable将从main线程中调用，而可观察的资源则是在Schedulers.io()上订阅的。())问题：考虑到

浏览 5提问于2017-10-18得票数 3

1回答

反应性编程与基于线程的编程

java、multithreading、rx-java、reactive-programming、spring-webflux

我是这个概念的新手，我想对这个话题有一个很好的理解。为了说明我的观点，我想作一个类比。在使用反应堆学习Java中的反应性编程时。我遇到了一种情况，当对象订阅时，主线程被阻塞，并发生一些延迟事件。据我所知，他们正试图通过将这些订阅服务器移动到其他线程来使其异步。但是如果是这样的话

浏览 1提问于2021-07-25得票数 2

回答已采纳

点击加载更多