13 #include <ucp/api/ucp.h>
15 #include <ucxx/python/future.h>
16 #include <ucxx/python/notifier.h>
17 #include <ucxx/worker.h>
46 Worker(std::shared_ptr<Context> context,
47 const bool enableDelayedSubmission =
false,
48 const bool enableFuture =
false);
86 std::shared_ptr<Context> context,
const bool enableDelayedSubmission,
const bool enableFuture);
120 [[nodiscard]] std::shared_ptr<::ucxx::Future>
getFuture()
override;
Component encapsulating a UCP worker.
Definition: worker.h:44
Specialized Python implementation of a ucxx::Worker.
Definition: worker.h:29
RequestNotifierWaitState waitRequestNotifier(uint64_t periodNs) override
Block until a request event.
friend std::shared_ptr<::ucxx::Worker > createWorker(std::shared_ptr< Context > context, const bool enableDelayedSubmission, const bool enableFuture)
Constructor of shared_ptr<ucxx::python::Worker>.
void populateFuturesPool() override
Populate the Python futures pool.
void runRequestNotifier() override
Notify Python futures of each completed communication request.
void clearFuturesPool() override
Clear the futures pool.
std::shared_ptr<::ucxx::Future > getFuture() override
Get a Python future from the pool.
void stopRequestNotifierThread() override
Signal the notifier to terminate.
RequestNotifierWaitState
The state with which a wait operation completed.
Definition: notifier.h:26