Когда безопасно отказаться от GRPC STUB и Channel в C ++ (API обратного вызова)? ⇐ C++

[Anonymous]

Я строю A c ++ grpc client , используя API обратного вызова . Клиент отправляет много асинхронных RPC, ожидает, что все они завершат, а затем немедленно выходят. 0). < /P>
Добавление короткого сна после последнего RPC помогает, но я хотел бы избежать произвольных задержек и отключаться чисто и детерминированно. GRPC гарантирует, что внутренние потоки не выполняются после окончания последнего обратного вызова?#include
#include
#include
#include

// Dummy placeholders
using RequestType = MyRequest;
using ResponseType = MyResponse;
using MyService = my::proto::MyService;

class PendingCallsCounter {
public:
void increment() {
std::lock_guard lock(mutex_);
++count_;
}

void decrement() {
std::lock_guard lock(mutex_);
if (--count_ == 0) {
cv_.notify_all();
}
}

void wait_until_finish() {
std::unique_lock lock(mutex_);
cv_.wait(lock, [this] { return count_ == 0; });
}

private:
std::mutex mutex_;
std::condition_variable cv_;
size_t count_ = 0;
};

struct RpcData {
grpc::ClientContext context;
RequestType request;
ResponseType response;
};

int main() {
auto channel = grpc::CreateChannel("localhost:50051", grpc::InsecureChannelCredentials());
auto stub = MyService::NewStub(channel);
PendingCallsCounter counter;

for (int i = 0; i < 1000; ++i) {
auto data = std::make_shared();
data->request.set_id(i); // Example payload
counter.increment();

stub->async()->MyMethod(&data->context, &data->request, &data->response,
[data, &counter](grpc::Status status) {
// Handle the result
counter.decrement();
});
}

counter.wait_until_finish();

// Adding a small sleep here seems to help avoid repeated-run issues:
// std::this_thread::sleep_for(std::chrono::milliseconds(100));

return 0;
}
< /code>
GRPC по -прежнему делает внутреннюю очистку потока, когда все обратные вызовы завершены?>

Подробнее здесь: https://stackoverflow.com/questions/797 ... llback-api