腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
主
线程
没有
等待
订阅
者
在
reactive
subscriber
中
完成
其
任务
java
、
spring
、
multithreading
、
spring-webflux
、
project-reactor
我
在
spring中有一个服务,它需要使用十种不同的方法来获取数据。 我想让这些方法并行执行一些DB操作,然后返回到父
线程
。但是父
线程
应该
等待
,直到所有的响应到来,然后返回一个响应。
在
我目前的方法
中
,我使用反应式mono异步执行所有方法,但主
线程
并不
等待
subscriber
方法
完成
。下面是我
订阅
的两个方法 private Mono<BaseResponse> getProfileDetai
浏览 13
提问于2020-01-09
得票数 1
回答已采纳
1
回答
Django -有更好的方式来发送大容量Twilio短信吗?
python
、
django
、
django-views
、
twilio
、
twilio-api
我目前正在使用以下views.py函数sendsmss,允许用户在用户
完成
包含要发送给
订阅
者
的短信的html表单后,对
其
订阅
者
列表执行大量短信: ifrequest.method == "POST":
浏览 5
提问于2020-03-09
得票数 0
回答已采纳
2
回答
为什么一个额外的异步操作使我的代码比根本不进行操作时更快?
c#
、
.net
、
multithreading
、
entity-framework
、
asynchronous
由于每个
订阅
者
都可能是不同变量的竞争状态,因此
在
发送文本消息之前,必须对每个
订阅
者
分别查询数据库。为了获得最佳性能,我使用.Net
任务
并行库(TPL)生成并行
线程
池
线程
,并在每个
线程
中
执行尽可能多的异步操作,以便最终尽快发送文本。
在
描述实际问题之前,需要提供一些关于代码的更多信息。一开始,代码
中
没有
异步操作。我刚刚用默认
任务
调度器将大约5000
浏览 3
提问于2015-08-16
得票数 4
回答已采纳
2
回答
反应性扩展能满足顺序不变性、同步性和多
线程
性吗?
c#
、
multithreading
、
system.reactive
、
data-synchronization
、
thread-synchronization
换句话说,我希望一个快速
订阅
者
等待
所有其他慢
订阅
者
完成
每个事件,然后再转到下一个事件。每个
订阅
服务器都有一个过滤器,因此它只处理感兴趣的事件。如果这样做有效,我可以很容易地利用我的系统
中
的所有核心,而不会遇到太多的多
线程
或同步问题。假设我们有一个
在
单个
线程
上生成的RX事件流。我们有两个RX用户,A和B。在这种情况下,订户A是快的(20毫秒),而订户B是慢的(500毫秒),所以我们需要某种锁或
浏览 1
提问于2015-01-21
得票数 2
回答已采纳
1
回答
一个类为另一个类注册事件处理程序是不是一种糟糕的做法?
c#
、
events
、
event-handling
事件
订阅
者
是否应该始终注册事件处理程序,或者其他类是否可以这样做?Glue { _publisher.Event += _
subscriber
.Handler;
浏览 25
提问于2018-05-31
得票数 0
回答已采纳
2
回答
在
另一个可观察对象
完成
时
订阅
另一个可观察对象
android
、
multithreading
、
rx-java
、
rx-android
保持简单和简短,如何在另一个
订阅
者
的onNext()方法
中
订阅
一个可观察对象,以便只有在当前可观察对象
完成
执行时才能进行嵌套
订阅
。这两个
订阅
都将在单独的
线程
上进行,并且要求第一个
线程
必须在第二个
线程
启动之前
完成
其
执行。makeObservable().subscribe(new
Subscriber
浏览 8
提问于2016-08-31
得票数 2
回答已采纳
1
回答
用未接收到的消息调试RxJava问题的最佳方法是什么
android
、
multithreading
、
rx-java
我有一个安卓应用程序,它有多个A类的观察
者
,
订阅
了B型的几个可观测值。
订阅
是
在
IO Scheduler和Android主
线程
上进行的。我遇到的问题是,随机,
在
一些工作之后,B发出的一条消息从未在A
中
接收,经过几个小时的破坏之后,我找不到原因。当问题发生时相关代码 "NEXT1“和"NEXT2”都是打印出来的,但是“接收”、“错误”、“
完成
”都
没有
。super msg>
subscriber
)
浏览 2
提问于2014-08-15
得票数 21
1
回答
保证日志文件不再写入日志文件后重命名日志文件
linux
、
bash
、
unix
、
log-files
在
远程机器
中
,我有一个连续运行的进程,它
订阅
某些数据并将其写入stdout (让我们将该进程称为
订阅
者
)。我现在处理这个问题的方式是手动停止
订阅
服务器,并从.sh脚本重新启动它。.sh脚本将把标准输出重定向到下一个日期的日志文件。
在
重新启动之间缺少几秒钟的数据对我来说
没有
问题。每天
在
特定时间从crontab调用一个新的.sh脚本 然后,此脚本按名称(即
订阅
服务器)终止所有进程。即使我找到了如何
完成
最
浏览 0
提问于2020-03-21
得票数 0
1
回答
ZeroMQ XPUB ()是否是一种解决方案,用于查找是否存在
订阅
者
并解决慢速合并综合症?
python
、
zeromq
、
pyzmq
、
xpub
我的用例: 运行1000多个
线程
(发布
者<
浏览 0
提问于2021-01-01
得票数 1
回答已采纳
1
回答
使用Mqtt
订阅
服务器与
主
类通信
java
、
multithreading
、
network-programming
、
mqtt
我有一个
主
类,它在另一个
线程
中
扩展一个mqtt
订阅
服务器(基本上是一个侦听消息到达的服务)。当
订阅
者
收到该消息时,我需要它转发到我的
主
类,以便它能够对该消息进行计算。
在
订阅
服务器
中
,我有一个messageArrived函数。我不确定该如何将这条信息传达给我的主要班级。我在想,也许是某种网络,比如将套接字从
订阅
者
发送到侦听的
主
类。但我想考虑一下其他建议。所有这些都是
浏览 1
提问于2015-11-19
得票数 0
回答已采纳
2
回答
我无法理解此异步方案的行为
c#
、
task-parallel-library
tasks = new List<Task>(); .ForEach( tasks.Add(Task.Factory.StartNew(() => ((Action<object, T>)
subscriber
)(sender, eventArgs))));} 当我使用Res
浏览 1
提问于2014-07-03
得票数 2
3
回答
在
订阅
服务器
线程
中
调用Thread.Sleep会导致发布服务器
线程
休眠
java
、
multithreading
、
design-patterns
我已经
在
我的应用程序
中
实现了发布和
订阅
模式,但是当我在任何一个
订阅
者
或任何一个
订阅
者
中
调用Thread.sleep()方法抛出异常时,所有其他
订阅
者
和发布
者
都会受到此影响,所以我如何防止这种情况发生。)); } } <
浏览 3
提问于2018-07-26
得票数 2
1
回答
多
线程
文件处理和数据库批量插入
java
、
multithreading
、
threadpool
、
executorservice
、
file-processing
我有一个Java
主
应用程序,它将逐行读取文件。每一行代表
订阅
者
数据。PS:输入文件大约有1500万订户数据,应用程序大约需要10-12个小时来处理。我需要将这个时间减少到2-3个小时左右,因为这个
任务
是一个迁移活动,我们得到的停机时间大约是4-5个小时。 我知道我需要使用多
线程
/
线程
池可能是Java
浏览 0
提问于2016-06-15
得票数 0
3
回答
Java Spring WebFlux vs RxJava
rx-java
、
reactive-programming
、
spring-webflux
、
project-reactor
在
我的学习过程
中
,我遇到了一些术语/库,比如Spring和RxJava。我希望有人能解释一下区别是什么,你在你的项目中使用了哪一个,以及为什么你做出了这个选择。这将问题简化为Spring Webflux
在
RxJava上的利弊?
浏览 2
提问于2019-06-05
得票数 33
回答已采纳
2
回答
以只有一个
订阅
者
使用的方式
在
java 9 Flow上向
订阅
者
发布数据。
java
、
java-9
、
flow
有
没有
一种方法可以将数据发布到
订阅
者
,使其只有一个
订阅
者
会收到数据?我试图实现的是,
订阅
者
发布
者
模型将作为具有多个读取
者
但只有一个发布
者
的队列工作。发布服务器发布数据后,第一个接收数据的
订阅
服务器将是唯一处理该数据的
订阅
服务器。 提前感谢!
浏览 0
提问于2018-05-01
得票数 5
1
回答
为什么Task.Wait()
在
Console.WriteLine() - .NET Core
中
的行为不像预期的那样?
.net
、
asynchronous
、
concurrency
、
task-parallel-library
、
.net-core
因此,Console.Read();阻塞UI
线程
,如果在素数
任务
完成
之前
没有
按下键,控制台中的输出将正确为216816。直到这里都是安全的。因此,我认为调用Wait();将具有与
主
UI
任务
块相同的效果(至少
在
OnCompleted回调之前调用),并
等待
完成
素数
任务
。这种情况确实发生了,但在这两种情况下(选项1和选项2),主
线程
等待
,然后
在
没有
任何
浏览 1
提问于2017-04-23
得票数 4
3
回答
发布服务器/
订阅
服务器模式的并发实现
java
、
concurrency
、
publish-subscribe
、
java.util.concurrent
我希望使用Java实现各种发布
者
/
订阅
者
模式,并且目前已经
没有
任何想法了。
在
我最初的实现
中
,每个
订阅
服务器都有自己的阻塞队列,发布
浏览 4
提问于2013-05-31
得票数 1
3
回答
获取可观察对象的最新值并立即发出该值
java
、
rx-java
、
reactive-programming
、
rx-android
有
没有
人知道如何实现这个目标?谢谢
浏览 0
提问于2016-05-04
得票数 28
回答已采纳
2
回答
将事件分派给
主
java
java
、
gwt
我有一个CountDownTimer类,当它
完成
计数时,它应该将一个事件分派给
主
java (或者任何使用它的类),让它知道它已经
完成
了。
浏览 3
提问于2014-03-08
得票数 0
回答已采纳
1
回答
Redis pub/亚相同的进程收听一个频道
node.js
、
express
、
redis
我遇到的问题是,当向同一个进程发布消息时,
订阅
者
似乎根本
没有
接收到它。console.log(channel,msgs); 我有一个redis客户端充当
订阅
者
,另一个作为发布
者
,这是您必须这样做的方式,但由于某种原因,消息
没有
被接收。是否存在某个进程无法侦听
其
发布的消息的限制?这似乎没什么意义。我可
浏览 1
提问于2015-06-19
得票数 3
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
聊聊reactive streams的processors
Reactive Spring实战 -- 理解Reactor的设计与实现
响应式编程——Reactor
Kotlin,RxJava与RxAndroid混合开发
C#中的委托和事件-Part.2
热门
标签
更多标签
活动推荐
运营活动
广告
关闭
领券