队列 任务
如何快速在 Apache DolphinScheduler 新扩展一个任务插件？
作者 | 代立冬 编辑 | Debra Chen Apache DolphinScheduler 是现代数据工作流编排平台，具有非常强大的可视化能力，DolphinScheduler 致力于使数据工程师、分析师、数据科学家等数据工作者都可以简单轻松地搭建各种数据工作流，让数据处理流程更简单可靠。 D ......
多个任务同同时异步处理+等待处理完毕
1.多个任务同时异步处理 // 设计线程池最大5个并发，其他进来排队 private ExecutorService executorPool = ThreadUtils.newDaemonFixedThreadPool(5,"APP-SCAN-THREAD"); private void comm ......
Window计划任务调用exe程序时日志文件没有写出问题
转自：https://blog.csdn.net/qq273766764/article/details/50729967/ 在之前写的exe程序中均有写文件日志操作，直接运行时是有日志文件的，但是配置到计划任务中就没有日志文件产生，程序的读写权限都已配置，但仍是没有日志文件之后百度了一下，原因是由 ......
【题解】集训队互测 2018 完美的队列
假设 \(n,m\) 同阶。 我们实际要做的是，对于一个 \(i\) 时间的 \(\mathbf{push}\) 操作 \(l,r,x\) 找到其被清空的时间 \(j\)，这样在 \([i,j)\) 这一段 \(x\) 就是存在的。最后只要合并相同 \(x\) 的区间即可。 将 \(l,r,x\) ......
在 Python 中，可以使用线程池（ThreadPoolExecutor）和 wait 方法来等待线程池中的所有任务完成。
import concurrent.futures # 创建一个线程池 with concurrent.futures.ThreadPoolExecutor() as executor: # 提交任务给线程池 task1 = executor.submit(func1, arg1) task2 = ......
About 单调队列优化多重背包
20230921 About 单调队列优化多重背包 前言 之前打了给代码，隐隐约约知道了意思。 但不完全明白~ 于是经过自己的钻研，终于理解。 模板题（P1776 宝物筛选） Statement 传送门 01 背包中每个数只能选一次改成可以选 \(s_i\) 次。 Solution 直接 dp 可以 ......
systemd时代的开机自启动任务
回到Systemd系列文章大纲 systemd时代的开机自启动任务 如果要让任务开机自启动，需将对应的Unit文件存放于/etc/systemd/system下。本文以Service Unit为例，但也支持让path Unit、timer Unit等类型的任务开机自启动。 systemd中服务开机自 ......
systemd timer：取代cron和at的定时任务
回到Systemd系列文章大纲 systemd timer：取代cron和at的定时任务 cron和systemd timer实现定时任务的比较 Linux环境下，cron是使用最广泛的定时任务工具，但它有一些不方便的地方。比如它默认： 只支持分钟级别精度的定时任务 定时规则太死板 当调度到本次任务 ......
flowable一直查询定时任务act_ru_timer_job问题
flowable: # 1. false: 默认值，Flowable 启动时，对比数据库表中保存的版本，如果不匹配。将抛出异常 # 2. true: 启动时会对数据库中所有表进行更新操作，如果表存在，不做处理，反之，自动创建表 # 3. create_drop: 启动时自动创建表，关闭时自动删除表 ......
Mysql 定时任务删除过期数据
1、查看数据库是否开启定时调度 SHOW VARIABLES LIKE 'event_scheduler';//查看OFF为关SET GLOBAL event_scheduler = ON;//设置开启，重启后失效 防止重启后失效 设置my.cnf，Linux一般在/etc/my.cnf ， 在[m ......
从 5s 到 0.5s！CompletableFuture 异步任务优化技巧，确实优雅！
一个接口可能需要调用 N 个其他服务的接口，这在项目开发中还是挺常见的。举个例子：用户请求获取订单信息，可能需要调用用户信息、商品详情、物流信息、商品推荐等接口，最后再汇总数据统一返回。 如果是串行（按顺序依次执行每个任务）执行的话，接口的响应速度会非常慢。考虑到这些接口之间有大部分都是 无前后顺序 ......
win10任务计划不执行
如果遇到不执行的情况，可以尝试一下操作 重新创建任务计划，创建时，先设置“只在用户登录时执行”，执行一次，时间在2分钟后后。 看下，如果执行成功，再改为“不管用户是否登录都要执行”,设置重复执行。 ......
优先队列
priority_queue<int> q;//大根堆priority_queue<int,vector<int>,greater<int> >q;//小根堆 q.top()//取得堆顶元素，并不会弹出 q.pop()//弹出堆顶元素 q.push()//往堆里面插入一个元素 q.empty()// ......
21_消息队列
消息队列 消息队列 1、任务级队列处理函数 2、中断级队列处理函数(带中断保护)已经在CMSIS接口中封装 但写入生产速度比消费速度快的时候,容易出现数据被覆盖 邮箱队列 创建、发送、接收、查询、删除 传数值 osEvent event = osMessageGet(myQueue01Handle, ......
阻塞队列
生产者消费者概念 生产者消费者是设计模式的一种。让生产者和消费者基于一个容器来解决强耦合问题。 生产者 消费者彼此之间不会直接通讯的，而是通过一个容器（队列）进行通讯。 所以生产者生产完数据后扔到容器中，不通用等待消费者来处理。 消费者不需要去找生产者要数据，直接从容器中获取即可。 而这种容器最常用 ......
9-TaskSet测试任务集
TaskSet 官方介绍：Class defining a set of tasks that a User will execute. 也就是一个把多个task集合起来的一个类，集合内的task的用法与在user类中的并没有多大差异，例如： from locust import TaskSet, ......
10-SequentialTaskset有顺序的测试任务集
SequentialTaskSet 有顺序的任务集 顾名思义，集合内的task是由上到下按顺序执行的，例如： from locust import SequentialTaskSet, task, FastHttpUser class MySTS(SequentialTaskSet): @task ......
priority_queue(优先队列)
优先队列底层模板：priority<type,container,function>,type:元素数据类型,container:容器一般是vector, function:比较函数 优先队列默认是大根堆，即堆顶元素为最大值:定义方法为 priority_queue<type>q或priority< ......
Spring Boot + Disruptor 实现消息队列，告诉你什么叫快、什么叫高效！
01、背景 工作中遇到项目使用Disruptor做消息队列,对你没看错,不是Kafka,也不是rabbitmq;Disruptor有个最大的优点就是快,还有一点它是开源的哦,下面做个简单的记录. 02、Disruptor介绍 Disruptor 是英国外汇交易公司LMAX开发的一个高性能队列，研发的 ......
[记] tokio多任务的延时
use tokio::{time}; async fn hh1(){ for _ in 0..10{ time::sleep(std::time::Duration::from_secs(3)).await; println!("11"); } } async fn hh2(){ for _ in ......
16_freeRTOS 任务控制函数
freeRTOS 任务控制函数 osThreadCreate 任务创建函数 osThreadTerminate osThreadTerminate(任务对象) 任务结束函数 task1 只打印了一次 获取任务ID printf("id = %d\n", osThreadGetId()); print ......
17_freeRTOS 任务状态切换
freeRTOS 任务状态切换 eTaskGetState 获取状态 printf("status %zd\n", osThreadGetState(osThreadGetId())); osThreadSuspend 挂起 osThreadSuspend(osThreadGetId()); ......
使用任务计划开机启动ASP.NET Core应用程序
ASP.NET Core应用程序现在是一个控制台应用程序，在Windows上直接双击启动，但如果想让开发完成的ASP.NET Core应用程序开机启动，可以将ASP.NET Core应用程序修改成Windows服务运行，但这需要额外添加代码，也可以使用IIS来托管ASP.NET Core应用程序，但 ......
消息队列 - RabbitMQ
RabbitMQ简介 RabbitMQ 是一个广泛使用的开源消息队列系统，它实现了高级消息队列协议（AMQP）标准，为分布式应用程序提供了强大的消息传递功能。RabbitMQ 是 Erlang 语言编写的，具有高度的可扩展性和可靠性，因此被广泛用于构建分布式、异步的消息通信系统。 以下是关于 Rab ......
异步任务创建
1.首先加入一个 init 方法进行异步初始化操作 private ExecutorService executorService; @PostConstruct public void init() { executorService = new ThreadPoolExecutor( Runti ......
## day13 - 栈与队列part03
day13 - 栈与队列part03 力扣239. 滑动窗口的最大值 思路：利用单调队列，很难想的出来。 因为每次是进一个数，弹出一个数，因此没必要每次都进行排序，只需要拿到最大值即可。 用单调队列实现，是一个双向队列 pop()函数：如果要pop的值是队列头部的值，那么就弹出，否则不操作。 pus ......
Sealos 新功能“定时任务”上线(省钱大杀器)
流量高峰时段资源不足？低流量时段服务器成本过高？ 本着好用又省钱的目标，sealos 推出 定时任务 功能，保证稳定的同时降低成本。 Sealos 国内集群：https://cloud.sealos.top Sealos 海外集群：https://cloud.sealos.io 原文链接：https ......
KingbaseES V8R6备份恢复案例之---备份crond计划任务的调整
案例说明： 在KingbaseES V8R6数据库通常备份建立的crond任务，默认由root用户建立，写入到/etc/cron.d/KINGBASECRON文件中，在有的生产环境限制了普通用户使用root的权限，创建计划任务可能失败，新的KingbaseES V8R6版本，将计划任务由数据库用户创 ......