Merge branch 'start_actor_from_anywhere' into 'master'

Allow an actor to be startet from anywhere

See merge request !43

emper/Actor.hpp

 // SPDX-License-Identifier: LGPL-3.0-or-later
-// Copyright © 2020 Florian Schmaus
+// Copyright © 2020 Florian Schmaus, Florian Fischer
 #pragma once
 
 #include <atomic>
 #include <chrono>
 
+#include "CallerEnvironment.hpp"
 #include "Fiber.hpp"
 #include "UnboundedBlockingMpscQueue.hpp"
 
@@ -55,13 +56,20 @@ class Actor {
 	void stop() { setState(Stopped); }
 
  public:
+	template <CallerEnvironment callerEnvironment = CallerEnvironment::EMPER>
 	void start() {
 		if (state.load(std::memory_order_acquire) != Stopped) return;
 
 		Fiber* actorFiber = Fiber::from(std::bind(&Actor::actorLoop, this));
-		runtime.schedule(*actorFiber);
+		if constexpr (callerEnvironment == CallerEnvironment::EMPER) {
+			runtime.schedule(*actorFiber);
+		} else {
+			runtime.scheduleFromAnywhere(*actorFiber);
+		}
 	}
 
+	void startFromAnywhere() { start<CallerEnvironment::ANYWHERE>(); }
+
 	void tell(T t) { queue.put(t); }
 
 	void tellFromAnywhere(T t) { queue.putFromAnywhere(t); }

tests/AlarmActorTest.cpp

 // SPDX-License-Identifier: LGPL-3.0-or-later
 // Copyright © 2020 Florian Fischer
-#include <algorithm>	// for copy
-#include <cstdlib>		// for exit, EXIT_FAILURE, EXIT_SUC...
-#include <iostream>		// for operator<<, basic_ostream
+#include <algorithm>	 // for copy
+#include <cstdlib>		 // for exit, EXIT_FAILURE, EXIT_SUC...
+#include <functional>	 // bind
+#include <iostream>		 // for operator<<, basic_ostream
 
 #include "Actor.hpp"										 // for Actor
 #include "BinaryPrivateSemaphore.hpp"		 // for BPS

tests/SimpleActorTest.cpp

 // SPDX-License-Identifier: LGPL-3.0-or-later
 // Copyright © 2020 Florian Schmaus
-#include <algorithm>	// for copy
-#include <atomic>			// for atomic_thread_fence, memory_...
-#include <cstdint>		// for uint64_t
-#include <cstdlib>		// for exit, EXIT_FAILURE, EXIT_SUC...
-#include <iostream>		// for operator<<, basic_ostream
+#include <algorithm>	 // for copy
+#include <atomic>			 // for atomic_thread_fence, memory_...
+#include <cstdint>		 // for uint64_t
+#include <cstdlib>		 // for exit, EXIT_FAILURE, EXIT_SUC...
+#include <functional>	 // for bind
+#include <iostream>		 // for operator<<, basic_ostream
 
 #include "Actor.hpp"										 // for Actor
 #include "CountingPrivateSemaphore.hpp"	 // for CPS

tests/TellActorFromAnywhereTest.cpp

 // SPDX-License-Identifier: LGPL-3.0-or-later
 // Copyright © 2020 Florian Schmaus
-#include <algorithm>	// for copy, copy_backward
-#include <cstdlib>		// for exit, EXIT_FAILURE, EXIT_SUCCESS
+#include <algorithm>	 // for copy, copy_backward
+#include <cstdlib>		 // for exit, EXIT_FAILURE, EXIT_SUCCESS
+#include <functional>	 // for bind
 #include <thread>
 
 #include "Actor.hpp"