MessageConmuser初始化的问题

[lakersWin]

你好，咨询一下，这个MessageConmuser[]的长度如何定义的，需要依据什么定义这个长度

[yangxuan-321]

您好，今日比较忙。现在才能回复您的邮件。我看了一下代码，这个数组长度的设置会影响并发消费的速度。所以说，这个值的大小应该要根据你消费者要做的业务的IO阻塞系数（阻塞程度），以及CPU的核数。来做一个大致的设置。我当时应该也是对该值的不同设置做了压测。不过找不到压测结果了。您要是有什么样的看法。可以使用邮件进行交流，或者加我微信：18772963897 在 2021-07-08 14:07:55，"drinkCola" ***@***.***> 写道： 你好，咨询一下，这个MessageConmuser[]的长度如何定义的，需要依据什么定义这个长度 — You are receiving this because you are subscribed to this thread. Reply to this email directly, view it on GitHub, or unsubscribe.

[lakersWin]

感谢回复，非常感谢。关于您说的地方我有一些不太明白，每个WorkHandler实现了run方法    workhandler被放入到WorkProcessor， 最后被workerPool.start()传入的线程池执行execute。消费者并发执行，从生产队列里拿数据，并且每个消费者都同时会消费多个任务。  就是到这里我不太明白，这个消费的数量是否需要跟线程池内部启动的线程的大小一样呢

…

------------------ 原始邮件 ------------------ 发件人: "yangxuan-321/disruptor-netty" ***@***.***>; 发送时间: 2021年7月8日(星期四) 晚上10:37 ***@***.***>; ***@***.******@***.***>; 主题: Re: [yangxuan-321/disruptor-netty] MessageConmuser初始化的问题 (#1) 您好，今日比较忙。现在才能回复您的邮件。我看了一下代码，这个数组长度的设置会影响并发消费的速度。所以说，这个值的大小应该要根据你消费者要做的业务的IO阻塞系数（阻塞程度），以及CPU的核数。来做一个大致的设置。我当时应该也是对该值的不同设置做了压测。不过找不到压测结果了。您要是有什么样的看法。可以使用邮件进行交流，或者加我微信：18772963897 在 2021-07-08 14:07:55，"drinkCola" ***@***.***> 写道： 你好，咨询一下，这个MessageConmuser[]的长度如何定义的，需要依据什么定义这个长度 — You are receiving this because you are subscribed to this thread. Reply to this email directly, view it on GitHub, or unsubscribe. — You are receiving this because you authored the thread. Reply to this email directly, view it on GitHub, or unsubscribe.