问题标签 [queueing]

上周我进行了一次电话采访并被困在一个问题上：

银行 1 有 5 名柜员，每个柜员每次独立服务一位客户；银行 2 有 5 名柜员，共享一个服务客户队列。你更喜欢哪家银行？为什么？

我不知道面试官想通过这个问题知道什么。我能做的只是说，银行2更好，因为大多数银行只有一个队列，一个队列可以确保如果一个柜员卡住了，没有人会等太久。

但我发现面试官似乎并不满意。

有人知道这个问题的最佳答案吗？

我想添加一个计划选项，以允许用户手动输入日期和时间，这会延迟他们的帖子发布到该特定日期/时间。因此，如果用户在一天内上传了 5 个帖子，但只想每天发布一个，那么他们可以为每个帖子输入一个特定的发布日期和时间（即 Post #1 publish on 1/8/18 3:30pm，发布 #2 于 18 年 1 月 13 日下午 4:00 等）

考虑使用 Celery 来解决这个问题。无法可视化如何将 Celery 任务连接到发布表单（或模型），因此用户可以选择根据他们的日程安排需要调整时间。如果您可以用视觉示例以及示例发生的位置（即views.py等）进行解释，将不胜感激。谢谢！

我试图了解 RabbitMQ 中消息删除的逻辑。

我的目标是即使没有客户端连接来读取它们，也使消息​​持续存在，这样当客户端重新连接时，消息正在等待它们。我可以使用持久的惰性队列，以便将消息持久保存到磁盘，并且我可以使用 HA 复制来确保多个节点获得所有排队消息的副本。

我希望使用主题或标头路由将消息发送到两个或多个队列，并让一个或多个客户端读取每个队列。

我有两个队列，A 和 B，由标头交换提供。队列 A 获取所有消息。队列 B 仅获取带有“归档”标头的消息。队列 A 有 3 个消费者正在阅读。队列 B 有 1 个消费者。如果 B 的消费者死了，但 A 的消费者继续确认消息，RabbitMQ 是删除消息还是继续存储？在 B 重新启动之前，队列 B 不会有任何人使用它，我希望这些消息保持可用以供以后使用。

到目前为止，我已经阅读了很多文档，但仍然没有找到明确的答案。

我正在尝试在节点应用程序中用 Kue.js 替换 AWS SQS。我担心的是，如果队列中没有添加任何项目。队列中有多少项将同时处理？

是不是像....处理器将一次或批量处理每个项目？

此外，如果从两个或多个不同的地方为同一个队列调用 queue.process()。将如何进行处理？

我正在尝试实现这个想法，但我不知道最好的方法是什么。

应该有一个排队等候游戏的按钮，并且每个游戏室应该有 3 名玩家。

我正在开发实时交互式可视化，使用流星并在前端做出反应。启动起来相当复杂的可视化，但相对容易通过原子更改进行更新。因此，我需要获取一次数据，转换数据，计算布局，然后观察数据的（原子）变化并更新可视化。

我的问题是：我应该如何处理这种情况，当数据发生变化时，在数据被获取、转换和可视化初始化的时间和我们开始观察变化的时间之间？

|---（订阅就绪）---（获取）---（转换数据）---（计算布局）------- ---------->

|---(订阅就绪)------------------------------------------ ----------------------（观察变化）--->

|---------(change1)---------(change2)------------- -------------------------------------------------- ->

我正在考虑首先开始更改观察，在我开始观察数据之前保存时间戳，获取数据，然后转换和计算布局并将所有更改排队，直到可视化准备就绪。

我有一个使用专有 DLL 控制一些步进电机的应用程序。我发现我偶尔会遇到错误，似乎我用来与控制器通信的功能太靠近了，并且没有时间让控制器做出响应。

如何将函数排队以便它们同步发生？

我正在尝试模拟 JSQ(d)（d 个采样队列的加入最短队列）系统，但在执行我的代码时遇到了问题。在这种情况下，我们假设 d=2。我希望在到达时确定工作大小（“X”的值）以及选择哪些 2 个队列将被采样和“JSQ-ed”（这可能会有所不同，尽管出于我的目的超出了这个最小值工作示例，这些必须在到达时确定）。

我收到

似乎是什么问题，我该如何解决这个问题？

考虑下面指定的系统和路由算法： 系统图像。让我们首先定义一些在模拟中有用的属性：

现在，让我们定义路由算法和之后的轨迹。

我们可以尝试完全在克隆函数中表达路由算法，如下所示：

我们现在收到以下问题：

我认为这与在我的“if”和“else if”语句的条件下调用函数有关，尽管我不确定我到底做错了什么。

M/M/c 允许对 c 服务器进行建模（在我的例子中：修理工）。通过 lambda（到达率）我生成事件的到达（在我的例子中：由某些机器触发的故障）。这意味着最大。系统中故障事件的数量等于触发它们的机器数量。（这意味着如果机器已经损坏，则无法生成故障事件......）。问题：排队包中的基本 MMC() 函数不考虑这个最大数量！我该如何实施？谢谢。

这里：arrivalRate 仅在不超过某个数量（触发故障的#machines）时才生成（故障）到达。