Python
Java
PHP
IOS
Android
Nodejs
JavaScript
Html5
Windows
Ubuntu
Linux
如何在运行时创建 celery 队列,以便工作人员拾取发送到该队列的任务?
我正在使用 django 1 4 celery 3 0 rabbitmq 为了描述该问题 我的系统中有许多内容网络 并且我需要一个队列来处理与每个网络相关的任务 然而 内容是在系统运行时动态创建的 因此我需要动态创建队列并让现有工作人员开始
django
Queue
Celery
AMQP
worker
NestJS Bull 队列:如何跳过测试环境中的处理?
我在用着通过 Bull 的 NestJS 队列 https docs nestjs com techniques queues并用 Jest 编写单元测试 我想跳过测试期间触发的作业的处理 存在 GH 问题Bull 的测试模式 https
Testing
jestjs
Queue
NESTJS
bull
SQL Server 进程队列竞争条件
我有一个订单队列 多个订单处理器通过存储过程访问该队列 每个处理器都会传递一个唯一的 ID 该 ID 用于锁定接下来的 20 个订单以供自己使用 然后 存储过程将这些记录返回给订单处理器以进行操作 有些情况下多个处理器能够检索相同的 Ord
sql
sqlserver
TSQL
Queue
racecondition
使用 sidekiq 处理两个独立的 Redis 实例?
下午好 我有两个独立但相关的应用程序 他们都应该有自己的后台队列 阅读 单独的 Sidekiq 和 Redis 进程 然而 我希望偶尔能够将工作推给app2的队列来自app1 从简单的队列 推送的角度来看 如果app1没有现有的 Sidek
rubyonrails
Redis
Queue
sidekiq
有没有更好的方法来实现队列的删除方法?
首先 请承认我确实想要一个功能Queue
c
NET
Queue
为什么Cocoa里没有队列?
我最近发现 Cocoa 中没有内置队列 在本例中为 Touch 为什么不 队列是计算机编程中最基本的数据结构之一 我看到有人建议使用NSMutableArray 但这对于弹出 出列来说效率极低 因为它需要删除索引 0 处的对象 这会将所有元
cocoatouch
cocoa
datastructures
Queue
使用 Celery 创建动态队列
这是我的场景 当用户登录我的网站时 我会为给定用户排队一堆任务 通常每个任务需要 100 毫秒 每个用户有 100 多个任务 这些任务排队到默认的 Celery 队列中 并且我有数百个工作线程正在运行 当任务在后端完成时 我使用 webso
python
Queue
Flask
Celery
需要帮助 Discord 机器人队列
我一直在尝试为不和谐机器人和我的 gt q命令基本上工作为join play queue同时 问题是它只能同时对 2 首歌曲进行排队 所以我需要帮助使其对多首歌曲进行排队 queues check queue def check queue
python
discordpy
Queue
java队列中Queue.Poll()返回null但Queue.size()>0
My code while Memo qRcv size gt 0 MessageReceived msg Memo qRcv poll 然后我得到了 2014 03 01 11 09 36 DEBUG Thread 16 threadQu
Java
null
Queue
Python - 使用线程或队列迭代调用函数的 for 循环
我对 python 相当陌生 正在制作一个脚本 允许将其他程序的点云数据引入 Autodesk Maya 我的脚本运行良好 但我想做的是让它更快 我有一个 for 循环 它遍历编号文件的列表 IE datafile001 txt dataf
python
Multithreading
forloop
Queue
python26
队列上的 IEnumerable 迭代器是否应该使项目出列
我创建了一个自定义通用队列 它实现了通用 IQueue 接口 该接口使用 System Collections Generic 命名空间中的通用队列作为私有内部队列 示例已清除不相关的代码 public interface IQueue
c
NET
Iterator
Queue
IEnumerable
装修调度系统
我想使用多个处理器并行执行线性运算 将复杂的数学函数拟合到某些数据集 假设我的机器有 8 个核心 我想要容纳 1000 个数据集 我期望的是某个系统将 1000 个数据集作为队列 并将它们发送到 8 个核心进行处理 因此它首先将 1000
c
Multithreading
Queue
multiprocessing
openmp
Node.js 中的作业队列
我正在node js 中寻找一个可以由php 调用的作业队列管理器 这是一个需要发送电子邮件 创建 pdf 文件等的 Web 应用程序 我想对这些应用程序执行异步 php 进程 流程示例 用户请求 php 页面 Php调用作业队列管理器并添
php
zendframework
nodejs
Queue
jobqueue
如何在没有线程或任务队列的情况下在 Flask 中运行后台作业
我正在使用 Flask restplus 构建 REST API 我的端点之一获取从客户端上传的文件并运行一些分析 该作业最多需要 30 秒 我不希望这项工作阻塞主进程 因此端点将立即返回 200 或 201 响应 作业仍然可以运行 结果将
python
Multithreading
Flask
Queue
Celery
Node.js 公牛队列中的作业陷入“等待”状态
我有一堆工作在公牛队列中 其中一个被卡住了 1 个多小时 通常需要大约 2 分钟才能运行 但没有失败 我无法使用我使用的 bull arena UI 将作业从活动状态中删除 因此我删除了 Redis 中活动作业的密钥 这消除了卡住的活动作业
nodejs
Redis
Queue
bullqueue
Java中的快速队列
我正在寻找一个快速queueJava 中的实现 我看到LinkedList实施Queue接口 但它只会像LinkedList正确的 有没有一种方法可以让队列更快 特别是对于add 我只需要poll add并检查empty 以后我可能还需要一
Java
Queue
如何在Mule中创建独占队列消费者?
在 ActiveMQ 中 您可以为队列配置独占消费者 例如 Queue Name Here consumer exclusive true 如何在 Mule 中配置像上面这样的独占消费者 您需要对队列名称进行 URL 编码 因为 Mule
Queue
Mule
ActiveMQ
持久 Akka 邮箱和无损
在 Akka 中 当一个 actor 在处理消息时死亡 内部onReceive 该消息丢失 有没有办法保证无损 有没有办法配置 Akka 始终保留消息before将他们发送到onReceive 以便在演员死亡时可以恢复并重播 也许像持久邮箱
Queue
persistence
akka
Actor
在Java中,为什么Stack是一个具体类,而Queue是一个接口?
Queue 的哪一个子类是 普通 队列 1 java util Stack 是 Java 1 0 的遗留类 它早于 Collections 框架很多年 坦率地说 它是一个例子horrible多方面的设计 一切都不是事情应有的样子 主要问题是
stack
Queue
JMS QueueSender 线程安全吗?
我想在多线程环境中使用 QueueSender Is QueueSender send 线程安全 No a MessageProducer QueueSender不是线程安全的 或者更具体地说 Session http java sun c
Java
Queue
JMS
threadsafety
«
1
2
3
4
5
6
...15
»