queue相关内容

使用 Monit 监控 Laravel Queue Worker

我目前正在考虑从 Supervisor 转移到 Monit 以监控 Laravel 队列工作者.主要原因是能够监控 CPU、内存和设置电子邮件警报(afaik with Supervisor 我必须安装另一个包),因为我想尽快监控其他东西,例如 Redis,也许还有 Web 服务器的整体稳定性和性能. 就我在过程监控方面的有限知识而言,Monit 更强大,更适合这项工作. 我能找到的关 ..
发布时间:2022-01-21 12:32:14 其他开发

Haskell 的标准队列包?

Haskell 有标准的队列实现吗?我看到了几个相当成熟的优先级队列实现,但没有简单的队列.Data.Sequence 看起来不错,但我认为我们可以使用更受限制的数据类型获得更好的性能.此外,限制操作(即不是双端队列)可以防止错误从错误的端出队. 编辑: 澄清一下,我希望有一个成熟的 Haskell 实现,最好是在 Haskell 平台或 Hackage 中. 解决方案 Dat ..
发布时间:2022-01-21 12:32:03 其他开发

用于 SQL 更新语句的 Java 单工作线程

我正在一个基于 Java 的服务器上工作,其中我将有多个线程(每个连接的用户一个线程 + 一些额外的线程).将涉及一些数据库连接,所以我在想每次服务器对数据库进行 SELECT 查询时,它都会为此启动一个新线程,以防止当前线程阻塞.我打算为此使用连接池,我想我知道该怎么做.(我研究过C3P0)但是,会有很多UPDATE 语句也涉及到,但是直接运行这些语句并不重要,这里有延迟也没关系.由于可能有很多 ..
发布时间:2022-01-21 12:31:31 Java开发

从队列更新活动的最佳方式

我的“Producer-Mediator-Consumer"模型的 Mediator 中有一个 LinkedBlockingQueue.Producer 首先更新 Mediator 添加到 activityQueue.接下来,Consumer/Activity 等待/侦听队列并抓取下一项. 我想要一个 Activity 来查看队列大小已更改并获取下一个项目.Mediator 无法看到 Act ..
发布时间:2022-01-21 12:31:17 移动开发

MySQL 表作为 FIFO/队列

我们如何将 Mysql 表视为有限的 FIFO 缓冲区(队列). 目标是: 一次表格只能有 N 行. 当插入一行时,应该删除最旧的行以保持行数为 N. 请建议方法. 更新:抱歉,正如许多人指出的那样,我将问题从 STACK 更改为 FIFO 队列 解决方案 过去的 Mysql 5 你可以使用触发器来实现这一点. http://dev.mysql.com/do ..
发布时间:2022-01-21 12:31:09 数据库

Gstreamer rtsp 播放(有声)

我是 gstreamer 的新手,简单地尝试从 Dlink 2103 摄像头获取 rtsp 视频流. 当我尝试时(只是视频): gst-launch rtspsrc location=rtsp://192.168.0.20/live1.sdp !\rtph264depay!\h264解析!capsfilter caps="video/x-h264,width=1280,height=800 ..
发布时间:2022-01-21 12:31:03 其他开发

Symfony2 作业队列还是并行处理?

有谁知道如何通过作业队列或并行处理在后台运行多个进程. 我有许多维护更新需要一些时间才能运行,并希望在后台执行此操作. 解决方案 我会推荐 Gearman 服务器,它证明了相当稳定,它完全在 Symfony2 之外,并且您必须启动并运行服务器(不知道您的托管选项是什么),但它可以完美地分配工作.在最精简的版本中,它只是将所有作业保存在内存中,但您可以将其配置为使用 sqlite 数据 ..
发布时间:2022-01-21 12:30:49 其他开发

ArrayDeque 和 LinkedBlockingDeque

只是想知道为什么他们制作了一个 LinkedBlockingDeque 而相同的非并发对应物是一个 ArrayDeque 它支持一个可调整大小的数组. LinkedBlockingQueue 使用一组节点,例如 LinkedList(即使没有实现 List). 我知道使用 ArrayBlockingQueue 的可能性,但如果想使用 ArrayBlockingDeque 怎么办?为什么 ..
发布时间:2022-01-21 12:30:38 Java开发

.NET webservice - 快速确认,但在后台继续处理

我正在构建将由供应商的应用程序使用的 .NET Web 服务,但我不确定如何完成以下操作: 供应商会致电我的网络服务提供一些信息,但希望快速回复确认,仅说明我已收到他们的信息.他们不在乎我用它做什么,也不想承认我已经完成了处理. 传递给我的信息需要在幕后做一些事情,并以对时间敏感的方式对信息采取行动 - 即在几分钟内采取一些行动.我将联系一些其他的网络服务,以及做一些数据库工作.显然,这是 ..
发布时间:2022-01-21 12:30:20 C#/.NET

如何确保我的事件仅由我的应用程序的一个实例处理?

在我们的架构中,我们有一个 Redis 服务器,用于缓存和发布事件. 我的问题如下 我有一条名为“CustomerUpdate"的消息 我有 1 个应用程序正在收听此消息 正在执行此应用程序的 3 个实例(服务器)以实现可扩展性 1 个数据库实例正在运行 此消息的处理程序之一将更新数据库 其他一些处理程序将清除内存缓存或对实例执行本地操作 是否有任何模式可以确保数据库不 ..
发布时间:2022-01-21 12:28:59 其他开发

Laravel 5.7“邮件验证"如何排队电子邮件发送

Laravel 5.7 包含的“电子邮件验证"功能运行良好,但异步电子邮件发送(在用户注册或重新发送链接页面期间)并不理想. 在 Laravel 5.7 中,有没有办法通过队列发送电子邮件验证电子邮件而无需重写整个电子邮件验证? 解决方案 没有内置的方法,但您可以通过扩展和覆盖轻松实现. 首先,创建一个扩展内置通知的新通知,并实现 ShouldQueue 协定(以启用排队).以 ..
发布时间:2022-01-21 12:28:41 其他开发

如何清除 NiFi 队列?

我们正在 NiFi 中创建一些流,在某些情况下可能会建立队列,但由于某种原因,流无法按预期工作. 在一天结束的时候,我想清除队列,并想以某种方式自动化它.问题是我们如何从后端删除队列?有什么方法可以实现吗? 解决方案 除了 Bryan 提到的显式“Drop Queue"功能外,您可能感兴趣的其他几个功能是“Back Pressure"和“FlowFile Expiration"设置关 ..
发布时间:2022-01-21 12:28:34 其他开发

Python threading.Thread 只能使用私有方法 self.__Thread_stop() 停止

我有一个函数,它接受一个大数组 x,y 对作为输入,它使用 numpy 和 scipy 进行一些复杂的曲线拟合,然后返回一个值.为了尝试加快速度,我尝试使用两个线程将数据提供给使用 Queue.Queue .一旦数据完成.我试图让线程终止,然后结束调用进程并将控制权返回给 shell. 我试图理解为什么我必须在 threading.Thread 中使用私有方法来停止我的线程并将控制权返回给命 ..
发布时间:2022-01-21 12:28:20 Python

飞镖中的未来队列

我想实现一个聊天系统. 我被困在用户非常快速地发送多个消息的地步.尽管所有消息都到达服务器,但以任何顺序. 所以我想实现一个队列,每条消息都应该 先入队 等待轮到它 轮到发帖请求 等待服务器响应大约 5 秒 如果响应在时间范围内到达并且状态正常,则消息发送,否则消息发送失败. 在第 5 点的任何情况下,消息都应出队,并给予下一条消息机会. 现在 ..
发布时间:2022-01-21 12:28:14 其他开发

python中一个好的持久同步队列

我不会立即关心 fifo 或 filo 选项,但将来可能会很好.. 我正在寻找一种快速而简单的方法,可以在磁盘上存储(最多一个数据或数千万个条目),可以由多个进程获取和放置.这些条目只是简单的 40 字节字符串,而不是 python 对象.并不真正需要 shelve 的所有功能. 我看过这个 http://code.activestate.com/lists/python-list/3 ..
发布时间:2022-01-21 12:28:07 Python