database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[enhancement](exchange) not use thread pool to handle exchange block (#23970)

Browse Source 
Co-authored-by: yiguolei <yiguolei@gmail.com>
This commit is contained in:
yiguolei
2023-09-07 19:40:48 +08:00
committed by GitHub
parent 20b3e5eafe
commit f2ebe65ea4
1 changed files with 4 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
be/src/service/internal_service.cpp
View File

@ -1100,20 +1100,10 @@ void PInternalServiceImpl::transmit_block(google::protobuf::RpcController* contr
int64_t receive_time = GetCurrentTimeNanos();
response->set_receive_time(receive_time);
if (!request->has_block() && config::brpc_light_work_pool_threads == -1) {
// under high concurrency, thread pool will have a lot of lock contention.
_transmit_block(controller, request, response, done, Status::OK());
return;
}
FifoThreadPool& pool = request->has_block() ? _heavy_work_pool : _light_work_pool;
bool ret = pool.try_offer([this, controller, request, response, done]() {
_transmit_block(controller, request, response, done, Status::OK());
});
if (!ret) {
offer_failed(response, done, pool);
return;
}
// under high concurrency, thread pool will have a lot of lock contention.
// May offer failed to the thread pool, so that we should avoid using thread
// pool here.
_transmit_block(controller, request, response, done, Status::OK());
}
void PInternalServiceImpl::transmit_block_by_http(google::protobuf::RpcController* controller,