ThreadPoolExecutor添加线程源码解析——addWorker 该方法的主要目的就是为了向线程池中创建线程(worker),并执行线程。 private boolean addWorker(Runnable firstTask, boolean core) { retry: for (; ...
分类：
编程语言 时间：
2021-07-27 17:35:04
阅读次数：
0
1、启动服务 systemctl restart mysqld.service 报错： 启动数据库Can‘t connect to MYSQL server through socket ''var/lib/mysql/mysql.cock(146 lock timed out:Retry tran ...
分类：
数据库 时间：
2021-07-05 17:35:04
阅读次数：
0
kafka它们属于消息队列；celery它们属于任务队列。 消息队列和任务队列，最大的不同之处就在于理念的不同 -- 消息队列传递的是“消息”，任务队列传递的是“任务”。 我们可以放到具体的应用场景上: 消息队列用来快速消费队列中的消息。比如日志处理场景，我们需要把不同服务器上的日志合并到一起，这时 ...
分类：
其他好文 时间：
2021-06-30 18:33:26
阅读次数：
0
情景： 用户发起request，并等待response返回。在本些views中，可能需要执行一段耗时的程序，那么用户就会等待很长时间，造成不好的用户体验，比如发送邮件、手机验证码等。 使用celery后，情况就不一样了。 解决： 将耗时的程序放到celery中执行。 Celery 是一个包含一系列的 ...
分类：
其他好文 时间：
2021-06-03 17:55:31
阅读次数：
0
以前写过一篇基于Springboot使用retry框架进行实现重试业务场景的文章： https://blog.csdn.net/qq_35387940/article/details/99676114 前言：重试这个需求场景在我们做项目的时候非常常见，实现这个场景的方法也是非常多， 定期轮询 Sch ...
分类：
编程语言 时间：
2021-05-24 07:26:44
阅读次数：
0
1.celery介绍 pip install celery == 4.4.7 pip install redis == 3.5.3 pip install eventlet == 0.26.1 Celery 是一个 基于python开发的分布式异步消息任务队列，通过它可以轻松的实现任务的异步处理， ...
分类：
其他好文 时间：
2021-04-08 13:57:36
阅读次数：
0
Celery是一个简单、灵活且可靠的，处理大量消息的分布式系统，专注于实时处理的异步任务队列，同时也支持任务调度。本系列将通过源码分析，和大家一起深入学习 Celery。本文是系列第二篇，继续探究 Celery 架构。 ...
分类：
其他好文 时间：
2021-03-29 12:19:38
阅读次数：
0
需求 有 A-F 6个任务，它们的执行关系如下： Task A, Task B Task C, Task D Task E, Task F 同一级内的任务可以并行，上一级任务做完了，才能进行下一级任务。 实现这样一个具有依赖关系的系列任务有很多种方法。这里采用的是Celery。 优点是：不用自己重新 ...
分类：
其他好文 时间：
2021-01-29 11:55:03
阅读次数：
0
1.快速测试和监控，启动多个celery worker，-A 指定项目目录， -P 指定方式，我这里以协程方式运行， -n指定name celery worker -A voice_quality_assurance_configure --loglevel=info -P eventlet -n ...
分类：
其他好文 时间：
2021-01-25 10:45:57
阅读次数：
0
老是整忘记，记录一下rabbitmq使用过程 1、No module named 'celery.backends.amqp' or KeyError: 'backend' #6384 pip install celery==4.4.6 2、关键代码 import subprocess from t ...
分类：
其他好文 时间：
2021-01-22 12:05:44
阅读次数：
0
