EventDispatcher的数量和火焰图堆栈中看到的并不一致

[Paragrf]

1. 问题背景

   • 首先注意到 EventDispatcher 的数量受以下两个参数限制：
     • FLAGS_task_group_ntags
     • FLAGS_event_dispatcher_num
   • 通过 view 观察到这两个 flag 的值均为 1，因此预期服务端应仅在 1 个 pthread 上执行 EventDispatcher::RunThis

2. 测试现象

   • 部署了一个 9 线程 的 brpc 服务端进行压力测试
   • 火焰图显示 9 个 worker 上均存在 EventDispatcher::RunThis 的堆栈

3. 疑问

   • 预期（单线程执行）与实际观测（多线程执行）存在差异，如何解释此现象？

4. 附件

   • 火焰图(svg图，可点选)
     

   • brpc 设置 EventDispatcher 数量的源码
     
     

   • view 上看到的 flag 值
     
     

[yanglimingcn]

查一下程序的堆栈信息，看看有多少event dispatcher的栈呢？预期event dispatcher的数量应该没问题。
可以使用https://github.com/apache/brpc/blob/master/tools/gdb_bthread_stack.py这个工具看bthread的栈。

[Paragrf]

从bthread的堆栈上来看确实只有一个bthread在执行EventDispatcher::RunThis
(gdb) bthread_list
id tid function has stack total:48
#0 48988396978187 0x763f40 brpc::ProcessInputMessage(void*) no
#1 46213848104972 0x763f40 brpc::ProcessInputMessage(void*) no
#2 43022687404099 0x763f40 brpc::ProcessInputMessage(void*) no
#3 47777216200801 0x763f40 brpc::ProcessInputMessage(void*) yes
#4 39204461478024 0x763f40 brpc::ProcessInputMessage(void*) no
#5 43198781063431 0x763f40 brpc::ProcessInputMessage(void*) yes
#6 48936857370928 0x763f40 brpc::ProcessInputMessage(void*) no
#7 13645111099776 0x763f40 brpc::ProcessInputMessage(void*) no
#8 44616120271411 0x763f40 brpc::ProcessInputMessage(void*) no
#9 49284749722169 0x763f40 brpc::ProcessInputMessage(void*) no
#10 45187350921807 0x763f40 brpc::ProcessInputMessage(void*) no
#11 47519518163746 0x763f40 brpc::ProcessInputMessage(void*) yes
#12 18494129177639 0x763f40 brpc::ProcessInputMessage(void*) no
#13 15977278342185 0x763f40 brpc::ProcessInputMessage(void*) no
#14 49160195671329 0x763f40 brpc::ProcessInputMessage(void*) no
#15 46132243727690 0x763f40 brpc::ProcessInputMessage(void*) no
#16 46785078756721 0x763f40 brpc::ProcessInputMessage(void*) no
#17 47652662150542 0x763f40 brpc::ProcessInputMessage(void*) yes
#18 48734993909137 0x763f40 brpc::ProcessInputMessage(void*) no
#19 50689204028843 0x763f40 brpc::ProcessInputMessage(void*) no
#20 47661252085288 0x763f40 brpc::ProcessInputMessage(void*) yes
#21 46441481373252 0x763f40 brpc::ProcessInputMessage(void*) no
#22 48614734825070 0x763f40 brpc::ProcessInputMessage(void*) no
#23 49718541420151 0x763f40 brpc::ProcessInputMessage(void*) yes
#24 44766444127915 0x763f40 brpc::ProcessInputMessage(void*) no
#25 46106473924280 0x763f40 brpc::ProcessInputMessage(void*) no
#26 49379239003973 0x763f40 brpc::ProcessInputMessage(void*) yes
#27 47296179865423 0x763f40 brpc::ProcessInputMessage(void*) yes
#28 45238890530650 0x763f40 brpc::ProcessInputMessage(void*) no
#29 46312632354737 0x763f40 brpc::ProcessInputMessage(void*) no
#30 44409961842650 0x763f40 brpc::ProcessInputMessage(void*) no
#31 48507360643108 0x763f40 brpc::ProcessInputMessage(void*) no
#32 4294969600 0x5ec6e0 brpc::GlobalUpdate(void*) yes
#33 4294969601 0x5d29f0 brpc::EventDispatcher::RunThis(void*) yes
#34 4294969602 0x5c5d50 brpc::Server::UpdateDerivedVars(void*) yes
#35 4294969603 0x5c5d50 brpc::Server::UpdateDerivedVars(void*) yes
#36 47553877903915 0x763f40 brpc::ProcessInputMessage(void*) no
#37 47210280520332 0x763f40 brpc::ProcessInputMessage(void*) no
#38 49155900705455 0x763f40 brpc::ProcessInputMessage(void*) no
#39 49795850832634 0x763f40 brpc::ProcessInputMessage(void*) yes
#40 50358491548716 0x763f40 brpc::ProcessInputMessage(void*) no
#41 52274046962738 0x763f40 brpc::ProcessInputMessage(void*) no
#42 46089294056569 0x763f40 brpc::ProcessInputMessage(void*) no
#43 43770011716805 0x763f40 brpc::ProcessInputMessage(void*) no
#44 45019847199945 0x763f40 brpc::ProcessInputMessage(void*) no
#45 47704201759946 0x763f40 brpc::ProcessInputMessage(void*) yes
#46 48747878812983 0x763f40 brpc::ProcessInputMessage(void*) no
#47 46351287061840 0x763f40 brpc::ProcessInputMessage(void*) no

[Paragrf]

但是火焰图上看到每一个worker上都有EventDispatcher::RunThis的堆栈，火焰图采样的时间是60s，有没有可能是同一个bthread在采样期间被不同的pthread都窃取了一遍

[yanglimingcn]

有这个可能性，到现在为止，这里可以排出代码问题了。