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);
85 friend std::shared_ptr<::ucxx::Worker>
createWorker(std::shared_ptr<Context> context,
86 const bool enableDelayedSubmission,
87 const bool enableFuture);
121 [[nodiscard]] std::shared_ptr<::ucxx::Future>
getFuture()
override;
Component encapsulating a UCP worker.
Definition: worker.h:45
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