producer-consumer
-
阻塞队列和多线程使用者,如何知道何时停止 我有一个单线程生产者,它创建一些任务对象,然后将其添加到一个(大小固定)中。 在我实际的最终实现中,我做了一些更接近你建议替换“||”的事情。(或)用“&&”(和),从某种意义
-
使用队列的生产者/使用者线程 我想创建某种线程应用程序。但我不确定在两者之间实现队列的最佳方法是什么。 因此,我有两个想法(这两个想法都可能完全错误)。我想知道哪个会更好,如果它们都很糟糕,那么实现队
-
-
RabbitMQ:快速生产者和慢速消费者 我有一个应用程序,它使用RabbitMQ作为消息队列,在两个组件之间发送/接收消息:发送方和接收方。发件人以非常快的方式发送消息。接收方接收消息,然后执行一些非常耗时的任务(主要是为
-
Java BlockingQueue with batching? 我对与Java BlockingQueue相同的数据结构感兴趣,除了它必须能够对队列中的对象进行批处理。换句话说,我希望生产者能够将对象放入队列中,但要打开使用者块,直到队列达到一定大小(批大小
-
Java 如何避免在循环中使用 Thread.sleep() 从我的主要开始,我开始两个线程,称为生产者和消费者。两者都包含循环。生产者环路是UDP服务器,因此它不需要休眠。我的问题是在消费者循环中。使用者循环从链接队列中删除对象,并将
-
kafka消费者能否在从一个主题轮询所有消息之前过滤消息? 据说消费者只能阅读整个主题。没有运气对经纪人进行评估以过滤消息。 这意味着我们必须使用/接收来自主题的所有消息,并在客户端过滤它们。 这太过分了。我想知道我们是否可以根据已
-
标签