queue相关内容

创建阻塞队列<T>在.NET 中?

我有一个场景,我有多个线程添加到一个队列,多个线程从同一个队列中读取.如果队列达到特定大小所有填充队列的线程将在添加时被阻塞,直到从队列中删除一个项目. 下面的解决方案是我现在正在使用的解决方案,我的问题是:如何改进?是否有一个对象已经在我应该使用的 BCL 中启用了这种行为? 内部类 BlockingCollection;: CollectionBase, IEnumerable{//t ..
发布时间:2021-12-01 09:31:27 C#/.NET

异步运行 PHP 任务

我在开发一个有点大的 Web 应用程序,后端主要使用 PHP.代码中有几个地方我需要完成一些任务,但我不想让用户等待结果.例如,在创建新帐户时,我需要向他们发送欢迎电子邮件.但是当他们点击“完成注册"按钮时,我不想让他们等到真正发送电子邮件,我只想开始这个过程,并立即向用户返回一条消息. 直到现在,在某些地方我一直在使用 exec() 感觉像是一个 hack 的东西.基本上做这样的事情: ..
发布时间:2021-11-30 13:43:15 PHP

Laravel - 作业在一台服务器上分派,在另一台服务器上处理

我正在研究 Laravel 应用程序的日志记录方面,amd 计划将数据发送到 SQS 以便稍后检索.但是,我想将作业从我的生产服务器分派到 AWS 队列,但随后有一个队列在单独的日志服务器上工作,该服务器侦听队列. 我了解如何设置 Queue worker 以监听 Queue,但是,Laravel 的 Jobs 是自我处理的.因此,当 Logging 服务器上的 worker 从 SQS 检 ..
发布时间:2021-11-27 11:13:53 其他开发

Amazon SQS 长轮询未返回所有消息

我需要在 1 次读取中读取我的 Amazon SQS 队列中的所有消息,然后根据创建的时间戳对其进行排序并对其进行业务逻辑. 为了确保检查所有 SQS 主机的消息,我启用了长轮询.我这样做的方法是将队列的默认等待时间设置为 10 秒.(任何大于 0 的值都将启用长轮询). 然而,当我试图读取队列时,它仍然没有给我所有的消息,我不得不多次读取才能获得所有的消息.我什至通过每个接收请求的代 ..
发布时间:2021-11-27 11:11:47 Java开发

在 SQS 队列中使用多个消费者

我知道可以使用多个线程来使用 SQS 队列.我想保证每条消息都会被消费一次.我知道可以更改消息的可见性超时,例如,等于我的处理时间.如果我的进程花费的时间超过可见性超时(例如连接速度较慢),则其他线程可以使用相同的消息. 保证消息被处理一次的最佳方法是什么? 解决方案 保证消息被处理一次的最佳方法是什么? 您要求的是保证 - 您不会得到保证.您可以将邮件被多次处理的概率降低 ..
发布时间:2021-11-27 11:10:12 其他开发

基于等待任务的队列

我想知道是否存在 ConcurrentQueue,类似于 BlockingCollection,其中从集合中取出不会阻塞,但是而是异步的,并且会导致异步等待,直到将项目放入队列中. 我已经提出了自己的实现,但它似乎没有按预期执行.我想知道我是否在重新发明已经存在的东西. 这是我的实现: 公共类 MessageQueue{ConcurrentQueuequeue = new Concu ..
发布时间:2021-11-26 11:03:48 C#/.NET

是否有固定大小的队列可以删除过多的元素?

我需要一个固定大小的队列.当我添加一个元素并且队列已满时,它应该自动删除最旧的元素. Java 中是否有针对此的现有实现? 解决方案 Java 语言和运行时中没有现有的实现.所有队列都扩展了 AbstractQueue,并且它的文档清楚地声明将元素添加到完整队列总是以异常结束.最好(并且非常简单)将 Queue 包装到您自己的类中以获得您需要的功能. 再说一次,因为所有队列都是 ..
发布时间:2021-11-25 19:49:47 Java Web开发

使用队列的生产者/消费者线程

我想创建某种Producer/Consumer 线程应用程序.但我不确定在两者之间实现队列的最佳方法是什么. 所以我有两个想法(这两个想法都可能完全错误).我想知道哪个更好,如果它们都糟糕,那么实现队列的最佳方法是什么.我关心的主要是我在这些示例中对队列的实现.我正在扩展一个 Queue 类,它是一个内部类并且是线程安全的.下面是两个例子,每个例子有 4 个类. 主类- public ..
发布时间:2021-11-25 14:11:29 Java Web开发

在 Java 中保存最后 N 个元素的大小受限队列

一个非常简单的 &关于 Java 库的快速问题:是否有一个现成的类,它实现了一个具有固定最大大小的 Queue - 即它总是允许添加元素,但它会默默地删除头元素以容纳新的空间添加元素. 当然,手动实现很简单: import java.util.LinkedList;公共类 LimitedQueue扩展 LinkedList{私有整数限制;公共有限队列(整数限制){this.limit = ..
发布时间:2021-11-25 13:36:47 Java Web开发

使用工作线程将项目出队

我一直在想办法解决我的需求,但在我的一生中,我就是想不出一个解决方案. 我有一个项目数据库,将它们存储为一种队列.(数据库已经实现,其他进程会向这个队列添加项目.) 这些项目需要大量的工作/时间来“处理",所以我需要能够:不断地从数据库中取出项目.对于每个项目运行一个新线程并处理该项目,然后返回真/假它已成功处理.(这将用于将其重新添加到数据库队列中) 但仅在当前活动线程数(每个 ..
发布时间:2021-11-24 09:33:41 C#

基于等待任务的队列

我想知道是否存在 ConcurrentQueue,类似于 BlockingCollection,其中从集合中取出不会阻塞,但是而是异步的,并且会导致异步等待,直到将项目放入队列中. 我已经提出了自己的实现,但它似乎没有按预期执行.我想知道我是否在重新发明已经存在的东西. 这是我的实现: 公共类 MessageQueue{ConcurrentQueuequeue = new Concu ..
发布时间:2021-11-24 09:01:30 C#

基于等待任务的队列

我想知道是否存在 ConcurrentQueue,类似于 BlockingCollection,其中从集合中取出不会阻塞,但是而是异步的,并且会导致异步等待,直到将项目放入队列中. 我已经提出了自己的实现,但它似乎没有按预期执行.我想知道我是否在重新发明已经存在的东西. 这是我的实现: 公共类 MessageQueue{ConcurrentQueuequeue = new Concu ..
发布时间:2021-11-22 11:06:22 C#

基于数组与基于列表的堆栈和队列

当同时实现为数组和链表时,我试图比较堆栈和队列操作的增长率(包括运行时间和空间).到目前为止,我只能找到队列 pop() 的平均情况运行时间,但没有任何内容全面探索这两种数据结构并比较它们的运行时间/空间行为.> 具体来说,我希望比较队列和堆栈的 push() 和 pop(),实现为 both 数组和链表(因此 2 个操作 x 2 个结构 x 2 个实现,或 8 个值). 此外,我很欣赏这 ..
发布时间:2021-11-18 04:48:27 其他开发

基于数组与基于列表的堆栈和队列

当同时实现为数组和链表时,我试图比较堆栈和队列操作的增长率(包括运行时间和空间).到目前为止,我只能找到队列 pop() 的平均情况运行时间,但没有任何内容全面探索这两种数据结构并比较它们的运行时间/空间行为.> 具体来说,我希望比较队列和堆栈的 push() 和 pop(),实现为 both 数组和链表(因此 2 个操作 x 2 个结构 x 2 个实现,或 8 个值). 此外,我很欣赏这 ..
发布时间:2021-11-18 04:48:15 其他开发

何时在数组列表上使用队列

在 ArrayList 上使用 Queue 的一个基本参数是 Queue 保证 FIFO 行为. 但是如果我向 ArrayList 添加 10 个元素,然后从第 0 个元素开始迭代这些元素,那么我将按照添加元素的相同顺序检索这些元素.从本质上讲,这保证了 FIFO 行为. 与传统的 ArrayList 相比,Queue 有什么特别之处? 解决方案 如果我给你一个 Queue 实 ..
发布时间:2021-11-17 23:59:34 其他开发

这里有什么问题?我收到一个 java.lang.ClassCastException 错误,但我看不出哪里出错了

这是我第一次真正使用列表和队列,所以这可能是一个非常简单的错误.是不是因为我的队列中充满了无法转换为整数的对象? //填充数组for(int i=0; i 解决方案 你真的应该使用泛型和 ArrayList/ArrayDeque,除非它真的很关键,而且你使用了很多原子类型,比如 int.那你应该看看http://labs.carrotsearch.com/hppc.html ..
发布时间:2021-11-17 23:44:47 其他开发

Laravel 多租户应用程序中的单个共享队列工作者

我正在构建一个多租户 Laravel 应用程序(在 Laravel 5.3 上),它允许每个租户为任何受支持的 Laravel 设置拥有自己的一组配置.目前这是通过使用我自己的实现覆盖默认的 Laravel Application 来实现的,该实现提供自定义配置加载器(覆盖默认的 Illuminate\Foundation\Bootstrap\LoadConfiguration).应用程序在引导时 ..
发布时间:2021-11-17 02:24:55 其他开发

是否有某种服务来排队 api 调用?

当客户在我的网站上填写表单时,我需要调用desk.com api 来创建案例.但是,有时 API 会因维护而关闭(太频繁了!),我的调用会失败. 目前我只是将详细信息写入登录错误并向自己发送电子邮件.然后我手动创建案例. 所以我正在考虑编写某种消息队列,而不是在进程中调用 api,我可以将请求放入队列中,然后让一些进程处理队列并进行 api 调用.如果 api 调用失败,他们会在下一个 ..
发布时间:2021-11-15 03:28:07 其他开发

使用队列的 Java Pig 拉丁语句子翻译器

我对 Java 非常陌生,正在尝试创建一个程序将一个句子翻译成 Pig Latin,将单词的第一个字母移到末尾,如果第一个字母是元音,则在末尾附加“y"并且否则在末尾的“ay".我需要为此使用队列.目前我的程序刚刚终止,我想知道是否有人能够发现我哪里出错了或者下一步要去哪里.谢谢! import MyQueue.QueueList;导入 java.util.Scanner; 公开课 P ..
发布时间:2021-11-12 04:09:35 其他开发

如何清除NiFi队列?

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