worker_builder.h

 
#pragma once
 
#include <memory>
#include <utility>
 
namespace ucxx {
 
// Forward declarations
class Context;
class Worker;
 
namespace experimental {
 
class WorkerBuilder {
 private:
  std::shared_ptr<Context> _context;     
  bool _enableDelayedSubmission{false};  
  bool _enableFuture{false};             
 
 public:
  explicit WorkerBuilder(std::shared_ptr<Context> context);
 
  WorkerBuilder& delayedSubmission(bool enable = true);
 
  WorkerBuilder& pythonFuture(bool enable = true);
 
  std::shared_ptr<Worker> build() const;
 
  operator std::shared_ptr<Worker>() const;
};
 
inline WorkerBuilder createWorker(std::shared_ptr<Context> context)
{
  return WorkerBuilder(std::move(context));
}
 
}  // namespace experimental
 
}  // namespace ucxx