如何通过Flux在不同的调度器上运行两个任务

文章/答案/技术大牛

发布

1回答

spring、flux、reactor

我尝试使用两种策略(串行和并行)来存储和解析一些原始数据 Flux<PanasonicData> f = Flux.create(sink -> dataRepo.addConsumer(sink::next)); Flux.from(f).publishOnSchedulers.parallel()).map(MyClass::parse).su

浏览 16提问于2019-12-13得票数 0

3回答

反应程序(反应堆)：为什么主线程被卡住了？

java、reactive-programming、project-reactor

我在学习项目反应堆的反应编程。我有以下测试用例：public void createAFlux_just() { } });} 通过执行测试我希望订阅<em

浏览 9提问于2020-09-28得票数 2

回答已采纳

1回答

在Web集群上创建Windows任务计划程序

asp.net、iis、web-applications、cluster-computing、windows-task-scheduler

我有ASP.NET web应用程序，它托管在上，两个不同的IIS服务器(servers和servers)用于http请求集群。我设计了web应用程序，用户可以在承载网站的IIS web服务器上创建和启动(运行)手动windows任务调度程序(但在我的情况下，它是托管在两个不同的web服务器上进

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

回答已采纳

2回答

Quartz.net调度程序内存泄漏

c#、nhibernate、windows-services、quartz.net、spring.net

我有一个调度程序窗口服务在服务器上运行，每个作业的调度时间不同。出现了两个问题：在一周内，服务运行正确，执行所有必须执行的任务，但在特定时间，它每次运行作业时都会在日志文件中抛出一个OutofMemoryException。在运行此调度程序服务的服务器中，任务<

浏览 9提问于2016-09-16得票数 2

1回答

CF模板从浏览器运行，但不从调度程序运行

coldfusion、coldfusion-10

Windows10/ ColdFusion 2K8 R2标准版我有2个计划任务调用此服务器上的一个托管网站。无论是从本地浏览器还是从远程浏览器调用，这两个任务都可以正常运行。两者都不是从调度程序运行的。不会抛出错误，也不会记录错误。如果我从调度器中手动运行任务，消息会显示它运行正常

浏览 0提问于2015-08-19得票数 1

1回答

在同一台机器上运行气流2.0中的多个调度器

airflow-scheduler

我知道气流2.0现在支持为HA并发运行多个调度器。我可以在相同的机器 (VM)上运行多个调度程序吗？如果我想要两个调度程序，只需要运行两次airflow scheduler就可以做到这一点，而不需要配置任何其他内容吗？

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

2回答

如何合并活动的反应流？

java、project-reactor

我刚刚开始探索项目反应堆，我目前对它的理解主要是以异步的方式从多个来源获取信息。例如，我有一个源，它快速生成数据，另一个源生成数据非常慢。我想合并这两个来源，并从他们两个返回的信息，尽快，我得到它。我试过这样的代码：public class ReactiveController { public Flux<String(10); private

浏览 4提问于2020-07-28得票数 1

回答已采纳

2回答

除了Quartz(自由和开放源码软件)和Flux(商业)之外，还有其他Java调度程序吗？

java、quartz-scheduler、job-scheduling

我有兴趣了解除了Quartz和Flux之外的其他作业调度包。考虑到web框架太多，我感到奇怪的是，实际上只有一个调度程序。还有其他的可能不那么出名或受欢迎吗？：不是真正的调度解决方案，而是批处理作业协调器等等。春季分批和石英有不同的目标。Spring提供了处理大量数据的</em

浏览 0提问于2011-01-06得票数 4

1回答

定义在同一个类的两个不同实例上的线程之间的通信？

java、multithreading

我有一个类(比如) Task.java，它执行一些任务调度活动。这个类包含两种类型的练习- 1)调度周期性任务和2)调度非周期性任务。周期性任务比非周期性任务具有更高的优先级。我将这个列表分成两个子列表，每个子列表包含不同的周期性任务，但可能重复非周期性任务。我将这些子列表提供给在两个

浏览 1提问于2014-04-14得票数 0

2回答

Windows任务调度器中的链式触发器

windows、scheduled-tasks、windows-task-scheduler

我在Windows任务调度程序中调度了一些任务。我安装了一个名为Bmail的第三方工具，它添加了一个独立从任务调度程序发送电子邮件的任务。它可以在给定的时间触发。有没有人知道如何设置让Bmail任务在原始任务运行时发送电子邮件？如何在任务调度器</e

浏览 2提问于2011-09-25得票数 1

2回答

Windows 2008标准中的VB6计划任务

windows-server-2008、vb6

任务由任务调度程序启动，进程开始运行(您可以在任务管理器中查看任务，但不使用资源、00 CPU、760 K RAM)，但什么也不会发生。在正常情况下，任务将使用25%的CPU和高达20 MB的RAM。当任务无法运行时，您仍然可以通过任务计划程序结束并启动它，但是什么也不会发生。如果您只通过exe运行</

浏览 0提问于2009-12-18得票数 1

1回答

调度器作业、从pid和睡眠

oracle、oracle11gr2

我有两个调度任务，运行不同的调度程序程序。每个调度程序程序运行相同的过程，但参数不同。我注意到，当一个调度程序作业要睡觉时，另一个也会睡觉。在我发现的调度器日志中，两个调度器jons具有不同</

浏览 1提问于2011-02-28得票数 2

回答已采纳

1回答

如何为部署在芹菜集群上的所有任务分配相同数量的资源？

docker、resources、celery、virtual-machine、scheduler

为了在科学实验中比较和对比三种不同算法的性能，我计划使用芹菜调度器。这些算法由三个不同的工具实现。它们可能实现了并行性，也可能没有实现并行性，我不想事先做任何假设。数据集包含10K个数据点。所有这三个工具都应该在所有数据点上运行；这相当于调度器调度了30K个任务。我想要的是在所有执行过程中为所有工具分配相同数量的资源。假设我<e

浏览 22提问于2020-05-28得票数 1

3回答

@Scheduled和Spring webflux

spring-webflux

我正在寻找一种在反应式API中使用计划任务的方法。我知道它使用线程池，所以它与webflux组件不是很兼容。你有相应的人来做这项工作吗？

浏览 87提问于2019-01-08得票数 8

1回答

RTOS STM32F4发现

rtos、freertos、stm32f4discovery

我实际上是在做我毕业的期末设计。我在STM32F4发现上使用了FreeRTOS。一切正常，但是任务的顺序不是我喜欢的。以下是我的代码的一部分： /*示例软件计时器的周期，以毫秒为单位指定，并使用portTICK_RATE_MS常量转换为节拍。

浏览 2提问于2016-06-20得票数 0

2回答

如何发送自动生成的电子邮件

asp-classic、html-email

我正在做一个任务调度程序。我被要求这样做，以便我正在处理的应用程序将发送电子邮件给用户，告诉他们他们有消息等待查看。我已经有一个部分，发送电子邮件工作正常，但只有当用户是积极地在一个网页上工作。我基本上是想让服务器决定在某个特定的时间发送电子邮件，例如午夜，告诉用户当天有多少条消息和会议没有更新。当没有收到用户的输入时，我不熟悉如何使应用程序工作。我要找的是:如何使ASP在预定<e

浏览 1提问于2015-06-25得票数 0

回答已采纳

1回答

电抗器输入通量的无序处理

java、project-reactor

我试图弄清楚如何获取一个Flux，它是一个输入数据序列，并行地通过一个阻塞调用运行它们，这个阻塞调用可能会重新排序该序列，然后通过第二个单线程阻塞调用运行重新排序的数据。查看，它建议我将阻塞调用转换为运行在调度程序上的Mono，该调度程序为我提供并行或单线程处理： private finalreturn

浏览 0提问于2019-11-05得票数 2

回答已采纳

1回答

flatMap调用后，反应器不支持runOn

java、reactive-programming、spring-data-mongodb、project-reactor

实际发生的情况是，flatMap操作在my-scheduler中执行，而我的process()方法中的代码不执行。有人能解释一下为什么会这样吗--这是一个bug，还是我做错了什么？如何让Flux中定义的所有操作在同一调度器上执行？

浏览 8提问于2019-07-06得票数 1

1回答

第三个转换使用前一个执行器执行

spring-webflux、project-reactor

我对在同一方法中使用多个Scheduler策略有疑问。.transform(fetchWikipediaGodInfo) .next();为什么我为每个转换定义不同的调度器，在最后一个中，在Max的执行中，在日志中，我观察到了前一个策略：fetchWikipediaGodInfo 在逻辑上，我希望对于max，代码使

浏览 0提问于2019-09-23得票数 0

1回答

工程堆中的平行通量与通量

java、spring-boot、spring-webflux、project-reactor

因此，我从文档中了解到，并行Flux实际上是将通量元素划分为单独的rails(本质上类似于分组)。就线程而言，这将是调度程序的工作。所以让我们来考虑一下这样的情况。所有这些都将在通过runOn()方法提供的同一个调度器实例上运行。让我们考虑以下情况： Mono<Response> = webClientCallAPi(..)//fu

浏览 2提问于2021-09-23得票数 5

回答已采纳

点击加载更多