Open mrwhyxxk opened 2 months ago
Is your feature request related to a problem? (你需要的功能是否与某个问题有关?) 代码如下,业务需求是:rpc提前返回给上游,然后server读执行后续的耗时操作(落盘)。
Describe the solution you'd like (描述你期望的解决方法) 1、我能否将brpc的rq视作一个mpmc的队列,这样就不用在回调中入队,后台消费线程出队? 2、如果可以,能否在done->Run()之后,“用户的耗时操作”之前,利用令牌桶进行控速
Describe alternatives you've considered (描述你想到的折衷方案)
Additional context/screenshots (更多上下文/截图)
不能看做unbounded queue,可以看下 task_group_runqueue_capacity 参数
Is your feature request related to a problem? (你需要的功能是否与某个问题有关?) 代码如下,业务需求是:rpc提前返回给上游,然后server读执行后续的耗时操作(落盘)。
Describe the solution you'd like (描述你期望的解决方法) 1、我能否将brpc的rq视作一个mpmc的队列,这样就不用在回调中入队,后台消费线程出队? 2、如果可以,能否在done->Run()之后,“用户的耗时操作”之前,利用令牌桶进行控速
Describe alternatives you've considered (描述你想到的折衷方案)
Additional context/screenshots (更多上下文/截图)