Tag: 队列

如何在java中实例化一个Queue对象？: 当我尝试： Queue<Integer> q = new Queue<Integer>(); 编译器给我一个错误。任何帮助？另外，如果我想初始化一个队列，我必须实现队列的方法吗？

如何有效地清除std ::队列？: 我正在使用std ::队列来实现JobQueue类。（基本上这个类以FIFO的方式处理每个工作）。在一种情况下，我想要一次性清除队列（从队列中删除所有作业）。我在std :: queue类中看不到任何清晰的方法。如何有效地实现JobQueue类的清除方法？我有一个简单的解决schemepopup一个循环，但我正在寻找更好的方法。 //Clears the job queue void JobQueue ::clearJobs() { // I want to avoid pop in a loop while (!m_Queue.empty()) { m_Queue.pop(); } }

在Java中保存最后N个元素的大小限制队列: 关于Java库的一个非常简单和快速的问题是：是否有一个现成的类，它实现了具有固定最大大小的Queue – 即它总是允许添加元素，但是它会默默移除头元素以容纳新增元素的空间。当然，手动实现它是微不足道的： import java.util.LinkedList; public class LimitedQueue<E> extends LinkedList<E> { private int limit; public LimitedQueue(int limit) { this.limit = limit; } @Override public boolean add(E o) { super.add(o); while (size() > limit) { super.remove(); } return true; } } 据我所知，在Java stdlib中没有标准的实现，但在Apache Commons中可能有这样的一个呢？

TThreadedQueue没有能力的多个消费者？: 尝试在单个生产者多个消费者scheme中使用TThreadedQueue（Generics.Collections）。（DELPHI-XE）。这个想法是推入对象到一个队列，让几个工作线程排空队列。尽pipe如此，它没有像预期的那样工作。当两个或两个以上工作线程调用PopItem时，访问冲突从TThreadedQueue抛出。如果对PopItem的调用是使用临界区域进行序列化的，则一切正常。当然TThreadedQueue应该能够处理多个消费者，所以我错过了什么，或者这是TThreadedQueue纯粹的错误？这是一个简单的例子来产生错误。 program TestThreadedQueue; {$APPTYPE CONSOLE} uses // FastMM4 in '..\..\..\FastMM4\FastMM4.pas', Windows, Messages, Classes, SysUtils, SyncObjs, Generics.Collections; type TThreadTaskMsg = class(TObject) private threadID : integer; threadMsg : string; public Constructor Create( ID : integer; const msg : string); end; type TThreadReader = class(TThread) private fPopQueue : TThreadedQueue<TObject>; fSync : […]

我可以在由Pool.imap调用的函数中使用多处理队列吗？: 我正在使用Python 2.7，并尝试在自己的进程中运行一些CPU繁重的任务。我希望能够发送消息回到父进程，以通知进程的当前状态。多处理队列似乎是完美的，但我不知道如何得到它的工作。所以，这是我的基本工作示例，减去使用队列。 import multiprocessing as mp import time def f(x): return x*x def main(): pool = mp.Pool() results = pool.imap_unordered(f, range(1, 6)) time.sleep(1) print str(results.next()) pool.close() pool.join() if __name__ == '__main__': main() 我试过用几种方式传递队列，并且他们得到错误消息“RuntimeError：队列对象应该只通过inheritance在进程间共享”。这是我根据我发现的早期答案尝试的方法之一。（我遇到同样的问题，试图使用Pool.map_async和Pool.imap） import multiprocessing as mp import time def f(args): x = args[0] q = args[1] q.put(str(x)) time.sleep(0.1) return […]

在SQS队列中使用许多消费者: 我知道可以使用多个线程来使用SQS队列。我想保证每个消息将被消耗一次。我知道可以改变消息的可见性超时，例如等于我的处理时间。如果我的进程花费比可见性超时更多的时间（例如，连接速度较慢），则其他线程可能会使用相同的消息。什么是最好的方法来保证消息将被处理一次？

如何在Objective-C中创build和使用队列？: 我想在我的Objective-C程序中使用队列数据结构。在C ++中我会使用STL队列。 Objective-C中的等效数据结构是什么？我如何推/stream行项目？

在.NET中限制Queue <T>的大小？: 我有一个Queue <T>对象，我已经初始化为2的容量，但显然这只是容量，并且随着我添加项目而不断扩大。是否已经有一个对象在达到限制时自动出队，或者是创build自己的inheritance类的最佳解决scheme？

RabbitMQ – 消息传送顺序: 我需要为我的新项目select一个新的队列代理。这次我需要一个支持pub / sub的可伸缩队列，并且保持消息顺序是必须的。我读亚历克西斯评论：他写道： “的确，我们认为RabbitMQ比Kafka提供更强的订单” 我阅读rabbitmq文档中的消息订购部分： “消息可以使用AMQP方法（basic.recover，basic.reject和basic.nack）返回队列，也可以由于通道closures而保留未确认的消息。”在2.7.0及更高版本如果队列中有多个用户，那么个人用户仍然可能观察到乱序信息，这是由于其他用户可能需要的消息的行为，从队列的angular度来看，信息总是以发布的顺序进行。 “ 如果我需要通过他们的订单来处理邮件，我只能使用rabbitMQ给每个消费者一个排队队列？ RabbitMQ仍然被认为是有序消息队列的一个很好的解决scheme吗？

我如何使用jQuery按顺序animation多个元素？: 我认为这将是简单的，但我仍然无法得到它的工作。通过点击一个button，我想要一个接一个地发生几个animation – 但现在所有的animation都是一次发生的。这是我的代码 – 有人可以告诉我我要去哪里吗？ $(".button").click(function(){ $("#header").animate({top: "-50"}, "slow") $("#something").animate({height: "hide"}, "slow") $("ul#menu").animate({top: "20", left: "0"}, "slow") $(".trigger").animate({height: "show", top: "110", left: "0"}, "slow"); });