GRPC同步服务器限制句柄线程

2022-07-04 00:00:00 multithreading grpc c++

我使用GRPC CPP示例"helloworold"代码来测试限制句柄线程。但我找不到任何方法来做这件事。

GRPC版本:1.15

Linux:Ubuntu 16.04

我将生成器设置如下:

builder.SetSyncServerOption(ServerBuilder::SyncServerOption::MIN_POLLERS, 1);
builder.SetSyncServerOption(ServerBuilder::SyncServerOption::MAX_POLLERS, 1);
builder.SetSyncServerOption(ServerBuilder::SyncServerOption::NUM_CQS, 1);

如下设置句柄:

class GreeterServiceImpl final : public Greeter::Service {
  Status SayHello(ServerContext* context, const HelloRequest* request,
                  HelloReply* reply) override {
    std::string prefix("Hello ");
    std::cout << "start " << std::this_thread::get_id() << std::endl;
    reply->set_message(prefix + request->name());

    //**** sleep 5s, keep this thread block ****
    std::this_thread::sleep_for(std::chrono::seconds(5));

    std::cout << "end " << std::this_thread::get_id() << std::endl;
    return Status::OK;
  }
};

我使用示例客户端,在100个线程中调用SayHello,服务器日志显示该线程被创建了100次。

在这个测试中,我的测试方法是不是错了?或者有什么东西错过了安装??


解决方案

您可以这样使用SetMaxThread:

grpc::ResourceQuota rq;
rq.SetMaxThreads(n);
builder.SetResourceQuota(rq);

似乎每个完成队列都需要一个线程。因此,当您有1个完成队列时,如果n=4,则剩余3个线程用于处理请求。

相关文章