- iOS/Objective-C 元类和类别
- objective-c - -1001 错误,当 NSURLSession 通过 httpproxy 和/etc/hosts
- java - 使用网络类获取 url 地址
- ios - 推送通知中不播放声音
我的问题是:
我有上千个传感器要调查每个传感器都有一个轮询间隔(不是固定的,而是随时间变化的)。
所以我需要一个接一个的,高效的投票。
为此,我可以使用优先级队列(以轮询时间戳作为键)。
问题是传感器可以忽略:
例如,如果有一个传感器需要每15分钟轮询一次,而有很多传感器需要每5分钟轮询一次,那么优先级队列可能会优先于第一个传感器。
因此,我可以使用几个优先级队列而不是一个,但如何选择下一个传感器进行轮询的问题仍然存在。
什么是解决我问题的理想办法?
谢谢。
最佳答案
如果使用计划的轮询时间作为优先级,则可能无法跟上轮询的进度,但在某些传感器从未进行轮询的情况下,不会出现饥饿问题。
Java的DelayQueue
非常适合这样做。将调度时间存储在Delayed
实例中(基于System.nanoTime()
),然后实现getDelay()
以计算该实例与当前System.nanoTime()
之间的差异。
因为DelayedQueue
是一个并发队列,所以多个使用者可以接受任务并运行它们,然后独立地重新调度新任务。这将有助于跟上负载并维护您的计划,因为在轮询速度较慢的传感器时,另一个线程可能正在等待下一个任务符合执行条件。
假设您有两个传感器:每秒轮询一次的传感器A和每3秒轮询一次的传感器B,以及按预定轮询时间排序的队列。
时间0:轮询,重新安排时间1
调查,重新安排时间3
时间1:轮询,重新安排时间2
时间2:轮询,重新安排时间3
时间3:民意调查,重新安排时间4
调查,重新安排时间6
时间3的轮询顺序还不确定,但b肯定会在时间4安排的任何传感器之前轮到它进行轮询。
从操作评论:
传感器不会离开队列,而是更新它们的密钥
那你做错了优先级队列没有密钥,但如果有,则不支持密钥变异。
队列是生产者向其添加元素、消费者从中移除元素的集合。如果其内容没有更改,请使用其他集合。
如果有时工作太多,无法按时完成每件事,你有两个基本的选择:做每件事,接受有些人会迟到,或者跳过一些工作,以便及时完成最重要的任务。哪种方法是合适的取决于您的应用程序,但第一种方法是脆弱的,因为您可能永远赶不上。
凡事迟到
如果你必须做所有的工作,但不在乎什么时候,你可能会使用两个优先权第一个是时间表,如前所述。第二个是“重要性”度量,用于对准备执行的任务进行优先级排序。
少数工作线程(可能只有一个)使用DelayedQueue
,根据它们的调度等待任务。然而,这些工作人员并没有直接执行任务,而是根据任务的重要性将其放入另一个BlockingQueue
中。较大的工作池使用此队列,首先执行最重要的任务。
如果平均负载大于可用容量,则此队列将继续增长否则,所有的工作最终都会完成,一旦任务准备好执行,您就可以设计任何您喜欢的优先级策略。
按时做某事
可能一个迟来的样本是毫无价值的,最好跳过投票,而不是进一步落后。在这种情况下,可以为每个任务指定一个“宽限期”。当它从DelayQueue
中出来时,检查当前时间是否在执行的宽限期内如果是,继续执行任务。否则,放弃任务并获取下一个任务宽限期可能是轮询频率的函数,较长的宽限期具有较长的宽限期,而跳过高频任务有助于快速清除队列,而不会长时间丢失样本。
混合的
您可以将“宽限期”思想与第一种方法结合起来,为最重要的任务提供最佳的按时执行机会,但在任务太迟而无法使用时跳过任务以赶上进度。
单线程
所有这些策略对于单线程执行任务仍然有用,但是当一个线程串行执行相对长时间运行的任务(如轮询物理传感器)时,保持计划是一个相当高的任务。
即使处理器是单核的,一次只执行一个线程,它仍然支持通过上下文切换进行线程调度,以便在其他任务被阻塞时在另一个任务上取得进展,这将更好地保持所需的调度。
关于java - 优先队列,同时防止饥饿,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/39754025/
我遇到一种情况,我需要从某个主题读取(正在进行的)消息并将它们放入另一个 Queue 中。我怀疑我是否需要 jms Queue 或者我可以对内存中的 java Queue 感到满意。我将通过同一 jv
队列的定义 队列(Queue):先进先出的线性表 队列是仅在队尾进行插入和队头进行删除操作的线性表 队头(front):线性表的表头端,即可删除端 队尾(rear):线性表的表尾端,即可插入端 由于这
Redis专题-队列 首先,想一想 Redis 适合做消息队列吗? 1、消息队列的消息存取需求是什么?redis中的解决方案是什么? 无非就是下面这几点: 0、数据可以顺序读
0. 学习目标 栈和队列是在程序设计中常见的数据类型,从数据结构的角度来讲,栈和队列也是线性表,是操作受限的线性表,它们的基本操作是线性表操作的子集,但从数据类型的角度来讲,它们与线性表又有着巨大的不
我想在 redis + Flask 和 Python 中实现一个队列。我已经用 RQ 实现了这样的查询,如果你有 Flask 应用程序和任务在同一台服务器上工作,它就可以正常工作。我想知道是否有可能创
我正在使用 Laravel 5.1,我有一个大约需要 2 分钟来处理的任务,这个任务特别是生成报告...... 现在,很明显,我不能让用户在我接受用户输入的同一页面上等待 2 分钟,而是我应该在后台处
我正在使用 Azure 队列,并且有多个不同的进程从队列中读取数据。 我的系统的构建方式假设每条消息只读取一次。 这个Microsoft article声称 Azure 队列具有至少一次传送保证,这可
我正在创建一个Thread::Queue元素数组。 我这样做是这样的: for (my $i=0; $i new; } 但是,当我在每个队列中填充这样的元素时 $queues[$index]->enq
我试图了解如何将我的 Mercurial 补丁推送到远程存储库(例如 bitbucket.org),而不必先应用它们(实际上提交它们)。我的动机是在最终完成之前首先对我的工作进行远程备份,并且能够与其
我的本地计算机上有一个 Mercurial 队列补丁,我需要与同事共享该补丁,但我不想将其提交到上游存储库。有没有一种简单的方法可以打包该补丁并与他分享? 最佳答案 mq 将补丁作为不带扩展名的文
Java 中是否有任何类提供与 Queue 相同的功能,但有返回对象的选项,并且不要删除它,只需将其设置在集合末尾? 最佳答案 Queue不直接提供这样的方法。但是,您可以使用 poll 和 add
我在Windows上使用Tortoise svn客户端,我需要能够一次提交来自不同子文件夹的更改文件-一次提交。像在提交之前将文件添加到队列中之类的?我该怎么做? Windows上是否还有另一个svn
好吧,我正在尝试对我的 DSAQueue 类进行单元测试,它显示我的 isEmpty()、isFull() 和 dequeue() 方法失败。 以下是我的 DSAQueue 代码。我认为我的 Dequ
我想尽量减少对传入请求的数据库查询。它目前需要写入 6 个不同的表。在返回响应之前不需要完成处理。因此,我考虑了 laravel 队列,但我想知道我是否也可以摆脱写入队列/作业表所需的单独查询。我可以
我正在学习队列数据结构。我想用链表创建队列。我想编程输出:10 20程序输出:队列为空-1 队列为空-1 我哪里出错了? 代码如下: class Node { int x; Node next
“当工作人员有空时,他们会根据主题的优先级列表从等待请求池中进行选择。在时间 t 到达的所有请求都可以在时间 t 进行分配。如果两名工作人员同时有空,则安排优先权分配给最近的工作最早安排的人。如果仍然
我正在开发一个巨大的应用程序,它使用一些子菜单、模式窗口、提示等。 现在,我想知道在此类应用程序中处理 Esc 和单击外部事件的正确方法。 $(document).keyup(function(e)
所以 如果我有一个队列 a --> b --> NULL; 当我使用函数时 void duplicate(QueueNodePtr pHead, QueueNodePtr *pTail) 它会给 a
我正在尝试为键盘输入实现 FIFO 队列,但似乎无法让它工作。我可以让键盘输入显示在液晶显示屏上,但这就是我能做的。我认为代码应该读取键盘输入并将其插入队列,然后弹出键盘输入并将值读取到液晶屏幕上。有
我正在学习算法和 DS。如何在 JavaScript 中使用队列? 我知道你可以做这样的事情。 var stack = []; stack.push(2); // stack is now
我是一名优秀的程序员,十分优秀!