14 SharedModule::SharedModule() =
default;
15 SharedModule::~SharedModule() =
default;
17 SharedModule::SharedModule(std::string
const& moduleLabel)
18 : moduleLabel_{moduleLabel}
27 std::set<std::string>
const&
37 "An error occurred while processing scheduling options for a " 44 <<
"async<art::InEvent>() cannot be called in combination with any " 45 "serialize<art::InEvent>(...) calls.\n";
49 throw e <<
"Either 'async<art::InEvent>()' or " 50 "'serialize<art::InEvent>(...)'\n" 51 "must be called in a shared module's constructor.\n";
56 chain_ = std::make_unique<SerialTaskQueueChain>(queues);
decltype(auto) constexpr cend(T &&obj)
ADL-aware version of std::cend.
std::set< std::string > resourceNames_
void serialize_for(std::string const &name)
std::set< std::string > const & sharedResources() const
std::unique_ptr< hep::concurrency::SerialTaskQueueChain > chain_
cet::coded_exception< errors::ErrorCodes, ExceptionDetail::translate > Exception
void createQueues(SharedResources const &resources)
decltype(auto) constexpr cbegin(T &&obj)
ADL-aware version of std::cbegin.
hep::concurrency::SerialTaskQueueChain * serialTaskQueueChain() const
void implicit_serialize()
std::vector< queue_ptr_t > createQueues(std::vector< std::string > const &resourceNames) const
decltype(auto) constexpr empty(T &&obj)
ADL-aware version of std::empty.