consumer相关内容

我的产品消费者挂起

请复制下面的程序,然后尝试在您的IDE中运行.这是一个简单的Producer消费者实现-当我使用一个Producer和一个Consumer线程时,它运行良好,但当每个使用2个消费者线程时却失败.请让我知道该程序挂起的原因或其他问题. import java.util.LinkedList; import java.util.Queue; public class PCQueue { p ..
发布时间:2020-07-04 18:55:18 Java开发

Java并发:多生产者一个消费者

我遇到的情况是,不同的线程填充一个队列(生产者),而一个消费者从该队列中检索元素.我的问题是,当从队列中检索这些元素之一时,某些元素会丢失(缺少信号?).生产者代码为: class Producer implements Runnable { private Consumer consumer; Producer(Consumer consumer) { this.con ..
发布时间:2020-07-04 18:54:11 Java开发

LMAX Disruptor模式中的慢速使用者(eventProcessor)问题的解决方案

使用中断器时,可能会有一个或多个使用者落后,并且由于该使用者缓慢,整个应用程序都受到了影响. 请记住,每个生产者(Publisher)和使用者(EventProcessor)都在单个线程上运行,那么解决缓慢的使用者问题的方法是什么? 我们可以在一个使用者上使用多个线程吗?如果没有,什么是更好的选择? 解决方案 一般来说,使用WorkerPool允许多个池化工作线程在单个使用者上 ..
发布时间:2020-06-11 19:45:47 其他开发

消费者选择器在activeMQ上的问题

场景:我向名为JUST.CN的队列发送了五万条消息。并每1000条消息设置一个消息属性字符串“ myfilter ='abc'”。现在,我创建具有相同选择器的使用者来使用消息。但是,尤其是在30000条消息之后,使用速度非常慢。我无法在activeMQ中更改默认配置。 核心代码如下: IDestination目标= SessionUtil.GetDestination(session,“ ..
发布时间:2020-06-01 19:13:58 其他开发

(可选)获取字段

我有一个像这样的类结构: public class Foo { private FooB foob; public Optional getFoob() { return Optional.ofNullable(foob); } } public class FooB { private int valA; publi ..
发布时间:2020-05-21 21:42:19 Java开发

生产者使用者使用线程

我正在编写一个程序,该程序使用多线程概念来实现Java中的Producer Consumer问题.以下是一些我应该怎么做的详细信息: 1)主线程应创建一个缓冲区,其容量指定为命令行参数.生产者线程和使用者线程的数量也指定为命令行参数.我应该为每个生产者和使用者线程分配一个唯一的编号.如何为生产者线程和使用者线程分配唯一编号? 2)生产者线程在无限循环中运行.它产生具有以下格式的数据项( ..
发布时间:2020-05-14 01:56:10 Java开发

我们使用使用者组通过多个使用者从经纪人读取数据,但是如何合并使用的数据?

我需要来自kafka经纪人的数据,但是为了快速访问,我正在使用多个具有相同组ID的消费者(称为消费者组).但是在每个消费者阅读之后,我们如何合并来自多个消费者的数据?有逻辑吗? 解决方案 通过设计,同一使用者组中的不同使用者彼此独立地处理数据. (这种行为使应用程序可以很好地扩展.) 但是在每个消费者阅读之后,我们如何合并来自多个消费者的数据?有逻辑吗? 使用Kafka的"Co ..
发布时间:2020-04-25 08:33:02 其他开发

具有lambda表达式和使用者断言的TestMethods的JQassistant规则

我们的项目几乎没有单元测试,其中断言作为lambda或consumer传递给测试类。示例如下。 如何编写密码规则约束这样的断言被识别,并且该方法没有被标记为没有断言。目前正在使用junit4:TestMethodWithoutAssertion 测试方法: @Test public void testSuccessfulIdempotency(){ transportConsu ..
发布时间:2019-01-14 12:25:50 Java相关

消耗Spring Hateoas Pageable

我有一个使用HAteoas的Rest-Service,以前没有分页的功能。现在我正在制作可分页的Json。我用Spring-Hateoas的开箱即用功能做到了这一点。但现在我正在坚持使用它,我想它确实没有很好的记录,如果是。 我的JSON如下所示: { “_embedded”:{ “vertragResourceList”:[ { “identifier”:728, “auszu ..
发布时间:2018-12-28 22:42:04 Java开发

可选的获取字段

我有这样的类结构: public class Foo { private FooB foob; public可选 getFoob(){ return Optional.ofNullable(foob); } } 公共类FooB { private int valA; public int getValA(){ return valA; } ..
发布时间:2018-12-05 20:41:12 Java开发