parmap_ = nullptr; // will be created lazily with the right parameters if needed (ie, in parallel)
workers_context_.resize(parallel_ ? SIMIX_context_get_nthreads() : 1, nullptr);
}
-SwappedContextFactory::~SwappedContextFactory()
-{
- delete parmap_;
-}
SwappedContext::SwappedContext(std::function<void()>&& code, smx_actor_t actor, SwappedContextFactory* factory)
: Context(std::move(code), actor), factory_(factory)
// We lazily create the parmap so that all options are actually processed when doing so.
if (parmap_ == nullptr)
- parmap_ = new simgrid::xbt::Parmap<smx_actor_t>(SIMIX_context_get_nthreads(), SIMIX_context_get_parallel_mode());
+ parmap_.reset(
+ new simgrid::xbt::Parmap<smx_actor_t>(SIMIX_context_get_nthreads(), SIMIX_context_get_parallel_mode()));
// Usually, Parmap::apply() executes the provided function on all elements of the array.
// Here, the executed function does not return the control to the parmap before all the array is processed:
#include "src/kernel/context/Context.hpp"
+#include <memory>
#include <vector>
namespace simgrid {
SwappedContextFactory();
SwappedContextFactory(const SwappedContextFactory&) = delete;
SwappedContextFactory& operator=(const SwappedContextFactory&) = delete;
- ~SwappedContextFactory() override;
void run_all() override;
private:
unsigned long process_index_ = 0; // Next actor to execute during sequential run_all()
/* For the parallel execution */
- simgrid::xbt::Parmap<smx_actor_t>* parmap_;
+ std::unique_ptr<simgrid::xbt::Parmap<smx_actor_t>> parmap_;
std::vector<SwappedContext*> workers_context_; /* space to save the worker's context in each thread */
std::atomic<uintptr_t> threads_working_{0}; /* number of threads that have started their work */
};