Home - News ( United States | United Kingdom | Italy | Germany ) - Football scores

Showing content from https://cloud.google.com/cpp/docs/reference/common/2.29.0/classgoogle_1_1cloud_1_1CompletionQueue below:

Class CompletionQueue (2.29.0) | C++ Client Libraries

Stay organized with collections Save and categorize content based on your preferences.

• 2.42.0-rc (latest)
• 2.41.0
• 2.40.0
• 2.39.0
• 2.38.0
• 2.37.0
• 2.36.0
• 2.35.0
• 2.34.0
• 2.33.0
• 2.32.0
• 2.31.0
• 2.30.0
• 2.29.0
• 2.28.0
• 2.27.0
• 2.26.0
• 2.25.1
• 2.24.0
• 2.23.0
• 2.22.1
• 2.21.0
• 2.20.0
• 2.19.0
• 2.18.0
• 2.17.0
• 2.16.0
• 2.15.1
• 2.14.0
• 2.13.0
• 2.12.0
• 2.11.0
• 2.10.1

Call the functor associated with asynchronous operations when they complete.

Run the completion queue event loop.

Note that more than one thread can call this member function, to create a pool of threads completing asynchronous operations.

Terminate the completion queue event loop.

Cancel all pending operations.

Create a timer that fires at deadline.

when should the timer expire.

a future that becomes satisfied after deadline. The result of the future is the time at which it expired, or an error Status if the timer did not run to expiration (e.g. it was cancelled).

Create a timer that fires after the duration.

when should the timer expire relative to the current time.

a placeholder to match the Rep tparam for duration type, the semantics of this template parameter are documented in std::chrono::duration<> (in brief, the underlying arithmetic type used to store the number of ticks), for our purposes it is simply a formal parameter.

a placeholder to match the Period tparam for duration type, the semantics of this template parameter are documented in std::chrono::duration<> (in brief, the length of the tick in seconds, expressed as a std::ratio<>), for our purposes it is simply a formal parameter.

a future that becomes satisfied after duration time has elapsed. The result of the future is the time at which it expired, or an error Status if the timer did not run to expiration (e.g. it was cancelled).

Make an asynchronous unary RPC.

a callable to start the asynchronous RPC.

the contents of the request.

an initialized request context to make the call.

the type of async_call. It must be invocable with (grpc::ClientContext*, Request const&, grpc::CompletionQueue*). Furthermore, it should return a std::unique_ptr<grpc::ClientAsyncResponseReaderInterface<Response>>>. These requirements are verified by internal::CheckAsyncUnaryRpcSignature<>, and this function is excluded from overload resolution if the parameters do not meet these requirements.

the type of the request parameter in the gRPC.

the response from the asynchronous RPC.

a future that becomes satisfied when the operation completes.

Make an asynchronous streaming read RPC.

Reading from the stream starts automatically, and the handler is notified of all interesting events in the stream. Note that then handler is called by any thread blocked on this object's Run() member function. However, only one callback in the handler is called at a time.

a callable to start the asynchronous RPC.

the contents of the request.

an initialized request context to make the call.

the callback to be invoked on each successful Read().

the callback to be invoked when the stream is closed.

the type of async_call. It must be invocable with parameters (grpc::ClientContext*, RequestType const&, grpc::CompletionQueue*). Furthermore, it should return a type convertible to std::unique_ptr<grpc::ClientAsyncReaderInterface<Response>>>. These requirements are verified by internal::AsyncStreamingReadRpcUnwrap<>, and this function is excluded from overload resolution if the parameters do not meet these requirements.

the type of the request in the streaming RPC.

the type of the response in the streaming RPC.

the type of the on_read callback.

the type of the on_finish callback.

Asynchronously run a functor on a thread Run()ning the CompletionQueue.

the functor to call in one of the CompletionQueue's threads.

the type of functor. It must satisfy std::is_invocable<Functor>.

Asynchronously run a functor on a thread Run()ning the CompletionQueue.

the functor to call in one of the CompletionQueue's threads.

the type of functor. It must satisfy std::is_invocable<Functor>.

Asynchronously wait for a connection to become ready.

the channel on which to wait for state changes

give up waiting for the state change if this deadline passes

future<> which will be satisfied when either of these events happen: (a) the connection is ready, (b) the connection permanently failed, (c) deadline passes before (a) or (b) happen; the future will be satisfied with StatusCode::kOk for (a), StatusCode::kCancelled for (b) and StatusCode::kDeadlineExceeded for (c)

Except as otherwise noted, the content of this page is licensed under the Creative Commons Attribution 4.0 License, and code samples are licensed under the Apache 2.0 License. For details, see the Google Developers Site Policies. Java is a registered trademark of Oracle and/or its affiliates.

Last updated 2025-08-14 UTC.

[[["Easy to understand","easyToUnderstand","thumb-up"],["Solved my problem","solvedMyProblem","thumb-up"],["Other","otherUp","thumb-up"]],[["Hard to understand","hardToUnderstand","thumb-down"],["Incorrect information or sample code","incorrectInformationOrSampleCode","thumb-down"],["Missing the information/samples I need","missingTheInformationSamplesINeed","thumb-down"],["Other","otherDown","thumb-down"]],["Last updated 2025-08-14 UTC."],[[["The document details the `CompletionQueue` class in the Google Cloud C++ library, which manages asynchronous operations and their completion."],["The `CompletionQueue` class supports running an event loop with `Run()`, terminating this loop with `Shutdown()`, and canceling all pending operations using `CancelAll()`."],["The `MakeDeadlineTimer` and `MakeRelativeTimer` functions are available for creating timers that expire at a specific deadline or after a duration, respectively."],["Asynchronous unary RPCs can be made using the `MakeUnaryRpc` function, and streaming read RPCs can be managed with the `MakeStreamingReadRpc` function, both of which are intended for internal use by the library rather than direct application use."],["Functions `RunAsync` allow users to run a functor on the `CompletionQueue`'s threads, while `AsyncWaitConnectionReady` asynchronously waits for a gRPC channel to connect or fail, allowing for status updates."]]],[]]

RetroSearch is an open source project built by @garambo | Open a GitHub Issue

Search and Browse the WWW like it's 1997 | Search results from DuckDuckGo

HTML: 3.2 | Encoding: UTF-8 | Version: 0.7.4