我有一个从runnable创建的单声道。我使用具有固定线程大小的ExecutorService来创建调度程序实例。我使用下面的代码创建了多个Mono，并订阅了它们。Mono.fromRunnable(new Runnable() {}).subscribeOn(scheduler) 由于来自多个调用的调用，这些订阅可能会并行发生，而且
浏览 39提问于2021-10-11得票数 0
Mono.empty()} // ReturnsMono.error(new Exception()) if error, otherwise Mono of Object
public Mono<Object> execute(Object.flatMap(dontcare -> this.save
浏览 10提问于2020-03-24得票数 6
回答已采纳
2回答
线程安全发行者
、、
系统应该只在每个T key的第一个请求时才订阅，并且应该取消订阅一旦不再保留给定密钥的侦听器。ConcurrentHashMap中，并使用线程池执行器运行对真正长的订阅和非子描述方法的调用： private final int，活动线程可以在输入假分支和执行Runnable之间
浏览 0提问于2014-07-08得票数 1
回答已采纳
doFinally是在同一个线程上执行的吗？下面的代码会阻塞主线程吗？mono.doFinally(v -> {}); 如果是这样的话，在doFinally的单独线程中执行cleanDirectory的
浏览 53提问于2020-10-30得票数 1
回答已采纳
我知道如何使用处理程序和runnable来定期调用方法。但是现在我想在一定的时间间隔内调用多个方法。下面是我的一个类中的代码： private Runnable runnable = new Runnable() {//Do something based on the index value
浏览 3提问于2016-10-04得票数 0
回答已采纳
我有一个java类来处理多线程订阅服务。通过实现可订阅接口，可以将任务提交给服务并定期执行。取消订阅现有任务
订阅由外部控制线程添加/删除，但延迟仅由内部工作线程引起。例如，如果工作线程没有从上次执行中找到更新，或者例如，如果线程只需要在00.00 - 23.00之间执行，则可能发生这种情况。我的问题是，一个工作线程可以调用delay()
浏览 3提问于2015-11-05得票数 1
回答已采纳
实际上，我对集会时间和订阅时间感到困惑。我知道mono很懒，在订阅之前不会执行。下面是一个方法。public Mono<UserbaseEntityResponse> getUserbaseDetailsForEntityId(String id) { }
这将在不调用订阅的情况下执行
浏览 0提问于2020-07-03得票数 1
回答已采纳
我正在尝试实验RxJava可观测和观察者代码。我的目标是检查底层源接收新数据值时是如何工作的。我的代码是：Runnable r = new Runnable() {
@Override然后，我有一个runnable，它在这个列表中添加了新的数字，在添加之间有一个时间间隔。我还没开始织
浏览 0提问于2021-01-09得票数 0
回答已采纳
在Android编程中，Handler和Runnables的用途是什么。它们之间是什么关系？另外，处理程序和线程有什么不同？
浏览 0提问于2014-02-16得票数 1
2回答
我正在开发一个相对简单的DB管理器，它以特定的方式接收大量文件、分析和编目信息。为此，我还在Swing中编写了一个简单的GUI。为了加快进程的速度，我想要实现对可并行的执行部分的多线程，以加快程序的速度。(new FileReader(this.datfile)); @Override);
浏览 6提问于2014-02-18得票数 0
回答已采纳
我想知道一个大开关语句和几个小开关语句之间是否有性能上的不同。 . .或者几个更小的开关语句而且，我知道反射将更容易编写代码，但这会导致很大的开销吗？
就像这样。
浏览 1提问于2014-07-29得票数 0
回答已采纳
1回答
我有这段代码，我想知道第一个输入和第二个输入执行时间不同的原因。我认为它应该花费相同的时间，因为我调用的是相同的方法，在两个对象中什么也不做。但是input1 (2个实例的交替)在我的计算机上花费了5秒钟。而input2 (这是两个实例之间的任意选择)在我的计算机上花费了17秒。final Runnable SECOND_INS
浏览 0提问于2019-09-19得票数 5
我正在尝试使用Platform.runLater从非JavaFX线程更新按钮文本，但文本不会更改 FXMLLoader loader = new FXMLLoader(getClass().getResource("GUI.fxml")); Map<String, Object> namespace = loader.getNamespace();
S
浏览 0提问于2019-07-10得票数 1
我有一个不等待executorService部件完成的executorService，它直接返回返回值，不需要等待下面是我的代码:请查看我是否正确地实现了executorService，如果需要，请帮助我更正它executorService = Executors.newSingleThreadExecutor();
Future f = executorService.submit(new Runnable
浏览 0提问于2016-11-02得票数 0
2回答
这是我在StackOverflow上的第一个问题(对我的英语很抱歉)。我也会尽力解释这个问题的。 progress.run();else {}Runnablesimulation has been completed."
浏览 0提问于2010-03-04得票数 7
据我所知，postDelayed()有两个参数runnable和duration delay。在kotlin中实际执行以下代码的是什么： sendMessage(MSG, params.id) }, duration)
这里，第一个是两个函数调用，第二个是持续时间延迟。runnable在
浏览 1提问于2018-03-29得票数 28
//Do same stuff here... });}就性能而言，method1和</e
浏览 0提问于2017-01-29得票数 0
我最近开始了android编程，这对我来说是全新的。我想在一段时间后更新声音id和绘图id，但没有更新@。在我使用的时间里：下面是活动代码：任何帮助都会对我有帮助。
浏览 14提问于2018-12-18得票数 0
根据我的假设，调度程序在另一个线程中的特定持续时间内运行调度任务。根据，它们是在调度器中使用的Runnable对象。这并不清楚，为什么他们使用Runnable对象，而没有在runnable上调用start()，新的线程堆栈就不会产生。或者Scheduler不创建用于运行计划任务的独立线程？akka调度器是如何在幕后工作的？
浏览 0提问于2016-08-19得票数 1
3回答
可运行的线程在哪个线程上运行？
、、、、
在StackOverflow中搜索之后，我找到了一个使用Runnable和Handler的解决方案，如下所示Runnablerunnable = new Runnable() { public void run() {
这个Runnable运行在哪个线程上？MainT
浏览 3提问于2017-12-06得票数 6
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
云直播
对象存储
实时音视频活动推荐
腾讯云开发者
