X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/247fba2eee61dc2a8e06c6f1339437dcb4481c3b..8d35ce927dd5951b952d5baa2c898db31b8fcb4c:/src/kernel/context/ContextThread.hpp diff --git a/src/kernel/context/ContextThread.hpp b/src/kernel/context/ContextThread.hpp index 6f6125a59b..a5e74f505b 100644 --- a/src/kernel/context/ContextThread.hpp +++ b/src/kernel/context/ContextThread.hpp @@ -1,12 +1,12 @@ -/* Copyright (c) 2009-2019. The SimGrid Team. All rights reserved. */ +/* Copyright (c) 2009-2020. The SimGrid Team. All rights reserved. */ /* This program is free software; you can redistribute it and/or modify it * under the terms of the license (GNU LGPL) which comes with this package. */ /* \file ThreadContext.hpp Context switching with native threads */ -#ifndef SIMGRID_SIMIX_THREAD_CONTEXT_HPP -#define SIMGRID_SIMIX_THREAD_CONTEXT_HPP +#ifndef SIMGRID_KERNEL_CONTEXT_THREAD_CONTEXT_HPP +#define SIMGRID_KERNEL_CONTEXT_THREAD_CONTEXT_HPP #include "simgrid/simix.hpp" #include "src/kernel/context/Context.hpp" @@ -20,9 +20,11 @@ namespace context { class XBT_PUBLIC ThreadContext : public AttachContext { public: - ThreadContext(std::function code, smx_actor_t actor, bool maestro); + ThreadContext(std::function&& code, actor::ActorImpl* actor, bool maestro); + ThreadContext(const ThreadContext&) = delete; + ThreadContext& operator=(const ThreadContext&) = delete; ~ThreadContext() override; - void stop() override; + XBT_ATTRIB_NORETURN void stop() override; void suspend() override; void attach_start() override; void attach_stop() override; @@ -46,12 +48,12 @@ private: virtual void yield_hook() { /* empty placeholder, called before yield(). Used in parallel mode */} virtual void stop_hook() { /* empty placeholder, called at stop(). Used in Java */} - static void* wrapper(void *param); + static void wrapper(ThreadContext* context); }; class XBT_PUBLIC SerialThreadContext : public ThreadContext { public: - SerialThreadContext(std::function code, smx_actor_t actor, bool maestro) + SerialThreadContext(std::function&& code, actor::ActorImpl* actor, bool maestro) : ThreadContext(std::move(code), actor, maestro) { } @@ -61,7 +63,7 @@ public: class ParallelThreadContext : public ThreadContext { public: - ParallelThreadContext(std::function code, smx_actor_t actor, bool maestro) + ParallelThreadContext(std::function&& code, actor::ActorImpl* actor, bool maestro) : ThreadContext(std::move(code), actor, maestro) { } @@ -80,8 +82,10 @@ private: class ThreadContextFactory : public ContextFactory { public: ThreadContextFactory(); + ThreadContextFactory(const ThreadContextFactory&) = delete; + ThreadContextFactory& operator=(const ThreadContextFactory&) = delete; ~ThreadContextFactory() override; - ThreadContext* create_context(std::function code, smx_actor_t actor) override + ThreadContext* create_context(std::function&& code, actor::ActorImpl* actor) override { bool maestro = not code; return create_context(std::move(code), actor, maestro); @@ -89,17 +93,20 @@ public: void run_all() override; // Optional methods: - ThreadContext* attach(smx_actor_t actor) override { return create_context(std::function(), actor, false); } - ThreadContext* create_maestro(std::function code, smx_actor_t actor) override + ThreadContext* attach(actor::ActorImpl* actor) override + { + return create_context(std::function(), actor, false); + } + ThreadContext* create_maestro(std::function&& code, actor::ActorImpl* actor) override { return create_context(std::move(code), actor, true); } private: - bool parallel_; - - ThreadContext* create_context(std::function code, smx_actor_t actor, bool maestro); + ThreadContext* create_context(std::function&& code, actor::ActorImpl* actor, bool maestro); }; -}}} // namespace +} // namespace context +} // namespace kernel +} // namespace simgrid #endif