diff --git a/emper/Runtime.cpp b/emper/Runtime.cpp
index e0875232c2cfb71f3b5f5c524e4b2388f30421ce..f6f2596b3725d9e943b66e42ba889de224e20450 100644
--- a/emper/Runtime.cpp
+++ b/emper/Runtime.cpp
@@ -28,8 +28,7 @@
#include "Fiber.hpp" // for Fiber
#include "FiberSource.hpp"
#include "NextFiberResult.hpp"
-#include "RuntimeStrategy.hpp" // for RuntimeStrategy
-#include "RuntimeStrategyFactory.hpp"
+#include "RuntimeStrategy.hpp"
#include "RuntimeStrategyStats.hpp" // for RuntimeStrategyStats
#include "WorkerLocalData.hpp"
#include "emper-config.h"
@@ -43,9 +42,9 @@
#include "stats/Worker.hpp"
#ifdef EMPER_DEFAULT_SCHEDULING_STRATEGY_WORK_STEALING
-#include "strategies/ws/WsStrategyFactory.hpp"
+#include "strategies/ws/WsStrategy.hpp"
#elif defined EMPER_DEFAULT_SCHEDULING_STRATEGY_LOCALITY_AWARE_WORK_STEALING
-#include "strategies/laws/LawsStrategyFactory.hpp"
+#include "strategies/laws/LawsStrategy.hpp"
#else
#error "Unknown default scheduling strategy"
#endif
@@ -62,11 +61,11 @@
std::mutex Runtime::currentRuntimeMutex;
Runtime* Runtime::currentRuntime;
-RuntimeStrategyFactory& Runtime::DEFAULT_STRATEGY =
+Runtime::StrategyFactory Runtime::DEFAULT_STRATEGY_FACTORY =
#ifdef EMPER_DEFAULT_SCHEDULING_STRATEGY_WORK_STEALING
- WsStrategyFactory::INSTANCE
+ WsStrategy::getFactory()
#elif defined EMPER_DEFAULT_SCHEDULING_STRATEGY_LOCALITY_AWARE_WORK_STEALING
- LawsStrategyFactory::INSTANCE
+ LawsStrategy::getFactory()
#else
#error "Unknown default scheduling strategy"
#endif
@@ -79,13 +78,13 @@ bool Runtime::guardPageTouchCausesExitSuccess = false;
struct sigaction Runtime::oldact {};
Runtime::Runtime(workerid_t workerCount, const std::vector<NewWorkerHook>& newWorkerHooks,
- bool pinWorkers, workerid_t pinningOffset, RuntimeStrategyFactory& strategyFactory,
+ bool pinWorkers, workerid_t pinningOffset, const StrategyFactory& strategyFactory,
unsigned int seed)
: workerCount(workerCount),
workerLatch(workerCount),
firstWorkerThreadExitLatch(workerCount),
secondWorkerThreadExitLatch(workerCount),
- strategy(strategyFactory.constructRuntimeStrategy(*this)),
+ strategy(strategyFactory(*this)),
scheduler(strategy->getScheduler()),
dispatcher(strategy->getDispatcher()),
contextManager(*(new ContextManager(*this))),
diff --git a/emper/Runtime.hpp b/emper/Runtime.hpp
index 87ec2bf9770daa56f3311cc86e5950ca126c6883..5daa0e973e45ed35e36122cd996ce5fab297721e 100644
--- a/emper/Runtime.hpp
+++ b/emper/Runtime.hpp
@@ -36,7 +36,6 @@ class Dispatcher;
class Fiber;
struct NextFiberResult;
class RuntimeStrategy;
-class RuntimeStrategyFactory;
class RuntimeStrategyStats;
template <typename D>
class WorkerLocalData;
@@ -66,6 +65,8 @@ class Runtime : public Logger<LogSubsystem::RUNTI> {
public:
using NewWorkerHook = std::function<void(workerid_t)>;
+ using StrategyFactory = std::function<RuntimeStrategy*(Runtime&)>;
+
private:
static std::mutex currentRuntimeMutex;
static Runtime* currentRuntime;
@@ -113,7 +114,7 @@ class Runtime : public Logger<LogSubsystem::RUNTI> {
WorkerSleepStrategy workerSleepStrategy;
emper::WakeupStrategy wakeupStrategy;
- static RuntimeStrategyFactory& DEFAULT_STRATEGY;
+ static StrategyFactory DEFAULT_STRATEGY_FACTORY;
static void printLastRuntimeStats(std::ostream& out = std::cout);
@@ -180,18 +181,18 @@ class Runtime : public Logger<LogSubsystem::RUNTI> {
public:
Runtime() : Runtime(getDefaultWorkerCount()) {}
- Runtime(workerid_t workerCount) : Runtime(workerCount, DEFAULT_STRATEGY) {}
+ Runtime(workerid_t workerCount) : Runtime(workerCount, DEFAULT_STRATEGY_FACTORY) {}
- Runtime(RuntimeStrategyFactory& strategyFactory)
+ Runtime(const StrategyFactory& strategyFactory)
: Runtime(getDefaultWorkerCount(), strategyFactory) {}
- Runtime(workerid_t workerCount, RuntimeStrategyFactory& strategyFactory,
+ Runtime(workerid_t workerCount, const StrategyFactory& strategyFactory,
unsigned int seed = std::random_device()())
: Runtime(workerCount, std::vector<NewWorkerHook>(), shouldPinWorkers(),
getDefaultPinningOffset(), strategyFactory, seed) {}
Runtime(workerid_t workerCount, const std::vector<NewWorkerHook>& newWorkerHooks, bool pinWorkers,
- workerid_t pinningOffset, RuntimeStrategyFactory& strategyFactory, unsigned int seed);
+ workerid_t pinningOffset, const StrategyFactory& strategyFactory, unsigned int seed);
~Runtime();
diff --git a/emper/RuntimeBuilder.hpp b/emper/RuntimeBuilder.hpp
index 5e3e8b2e7c535f50140319b0e5ef24ce8a7c467a..b8acbc236a91f0a253c7f8e5eaa37d712f26e5c4 100644
--- a/emper/RuntimeBuilder.hpp
+++ b/emper/RuntimeBuilder.hpp
@@ -1,5 +1,5 @@
// SPDX-License-Identifier: LGPL-3.0-or-later
-// Copyright © 2021 Florian Fischer
+// Copyright © 2021-2022 Florian Fischer, Florian Schmaus
#pragma once
#include <optional>
@@ -14,7 +14,7 @@ class RuntimeBuilder {
std::vector<Runtime::NewWorkerHook> newWorkerHooks;
- RuntimeStrategyFactory* strategyFactory = nullptr;
+ std::optional<Runtime::StrategyFactory> strategyFactory = std::nullopt;
std::optional<bool> pinWorkers = std::nullopt;
std::optional<workerid_t> pinningOffset = std::nullopt;
@@ -42,8 +42,8 @@ class RuntimeBuilder {
return *this;
};
- inline auto withStrategyFactory(RuntimeStrategyFactory* factory) -> RuntimeBuilder& {
- this->strategyFactory = factory;
+ inline auto withStrategyFactory(Runtime::StrategyFactory strategyFactory) -> RuntimeBuilder& {
+ this->strategyFactory = strategyFactory;
return *this;
};
@@ -56,8 +56,7 @@ class RuntimeBuilder {
auto workerCount =
this->workerCount != 0 ? this->workerCount : Runtime::getDefaultWorkerCount();
- auto* strategyFactory =
- this->strategyFactory != nullptr ? this->strategyFactory : &Runtime::DEFAULT_STRATEGY;
+ auto strategyFactory = this->strategyFactory.value_or(Runtime::DEFAULT_STRATEGY_FACTORY);
auto pinWorkers = this->pinWorkers.value_or(Runtime::shouldPinWorkers());
@@ -65,6 +64,6 @@ class RuntimeBuilder {
auto seed = this->seed.value_or(std::random_device()());
- return Runtime(workerCount, newWorkerHooks, pinWorkers, pinningOffset, *strategyFactory, seed);
+ return Runtime(workerCount, newWorkerHooks, pinWorkers, pinningOffset, strategyFactory, seed);
}
};
diff --git a/emper/strategies/laws/LawsStrategy.cpp b/emper/strategies/laws/LawsStrategy.cpp
index 603391b469f8b1273dafccf0142dc37b1670c4b6..3cf855f4a707e05a5326ee7d1d0e626b8c6c63fd 100644
--- a/emper/strategies/laws/LawsStrategy.cpp
+++ b/emper/strategies/laws/LawsStrategy.cpp
@@ -1,5 +1,5 @@
// SPDX-License-Identifier: LGPL-3.0-or-later
-// Copyright © 2020-2021 Florian Schmaus
+// Copyright © 2020-2022 Florian Schmaus
#include "LawsStrategy.hpp"
#include <functional>
@@ -11,6 +11,11 @@
thread_local LawsWorkerStats LawsStrategy::stats;
+auto LawsStrategy::getFactory() -> std::function<LawsStrategy*(Runtime&)> {
+ static auto factory = [](Runtime& runtime) { return new LawsStrategy(runtime); };
+ return factory;
+}
+
LawsStrategy::LawsStrategy(Runtime& runtime)
: AbstractWorkStealingStrategy(runtime),
scheduler(runtime, *this),
diff --git a/emper/strategies/laws/LawsStrategy.hpp b/emper/strategies/laws/LawsStrategy.hpp
index c2eea7ed0bba35ef6e19987cd764244f6f4780ac..dc124808ddc537378110625531eee7c511f43ed2 100644
--- a/emper/strategies/laws/LawsStrategy.hpp
+++ b/emper/strategies/laws/LawsStrategy.hpp
@@ -1,7 +1,8 @@
// SPDX-License-Identifier: LGPL-3.0-or-later
-// Copyright © 2020-2021 Florian Schmaus
+// Copyright © 2020-2022 Florian Schmaus
#pragma once
+#include <functional>
#include <memory>
#include "WorkerLocalData.hpp"
@@ -31,6 +32,8 @@ class LawsStrategy : public AbstractWorkStealingStrategy {
auto getDispatcher() -> LawsDispatcher& override;
public:
+ static auto getFactory() -> std::function<LawsStrategy*(Runtime&)>;
+
auto getStats() -> std::shared_ptr<RuntimeStrategyStats> override;
friend LawsScheduler;
diff --git a/emper/strategies/laws/LawsStrategyFactory.cpp b/emper/strategies/laws/LawsStrategyFactory.cpp
deleted file mode 100644
index 1dc946c030e9f545fed77b0bc03e4f937b5f696c..0000000000000000000000000000000000000000
--- a/emper/strategies/laws/LawsStrategyFactory.cpp
+++ /dev/null
@@ -1,11 +0,0 @@
-// SPDX-License-Identifier: LGPL-3.0-or-later
-// Copyright © 2021 Florian Schmaus
-#include "strategies/laws/LawsStrategyFactory.hpp"
-
-class Runtime;
-
-LawsStrategyFactory LawsStrategyFactory::INSTANCE;
-
-auto LawsStrategyFactory::constructRuntimeStrategy(Runtime& runtime) -> LawsStrategy* {
- return new LawsStrategy(runtime);
-}
diff --git a/emper/strategies/laws/LawsStrategyFactory.hpp b/emper/strategies/laws/LawsStrategyFactory.hpp
deleted file mode 100644
index 2ae89ea5090c5cea41c7c25ec4e13276fa5a3757..0000000000000000000000000000000000000000
--- a/emper/strategies/laws/LawsStrategyFactory.hpp
+++ /dev/null
@@ -1,18 +0,0 @@
-// SPDX-License-Identifier: LGPL-3.0-or-later
-// Copyright © 2021 Florian Schmaus
-#pragma once
-
-#include "RuntimeStrategyFactory.hpp"
-#include "strategies/laws/LawsStrategy.hpp"
-
-class Runtime;
-
-class LawsStrategyFactory : public RuntimeStrategyFactory {
- private:
- LawsStrategyFactory() = default;
-
- public:
- auto constructRuntimeStrategy(Runtime& runtime) -> LawsStrategy* override;
-
- static LawsStrategyFactory INSTANCE;
-};
diff --git a/emper/strategies/laws/meson.build b/emper/strategies/laws/meson.build
index b36183e6161325f749cec19c211683de87b64317..3297836ba79d00f5d0f0222b244b4ff60a63088f 100644
--- a/emper/strategies/laws/meson.build
+++ b/emper/strategies/laws/meson.build
@@ -1,6 +1,5 @@
emper_cpp_sources += files(
'LawsStrategy.cpp',
- 'LawsStrategyFactory.cpp',
'LawsStrategyStats.cpp',
'LawsScheduler.cpp',
'LawsDispatcher.cpp',
diff --git a/emper/strategies/ws/WsStrategy.cpp b/emper/strategies/ws/WsStrategy.cpp
index b6eb19e0c03ed9b2821ee7b68eeda6d9f1d1b36d..60c78df6be47f12b1268b36f6fed2356e132a033 100644
--- a/emper/strategies/ws/WsStrategy.cpp
+++ b/emper/strategies/ws/WsStrategy.cpp
@@ -1,5 +1,5 @@
// SPDX-License-Identifier: LGPL-3.0-or-later
-// Copyright © 2020-2021 Florian Schmaus
+// Copyright © 2020-2022 Florian Schmaus
#include "WsStrategy.hpp"
#include "WsDispatcher.hpp"
@@ -9,6 +9,13 @@
class Runtime;
class RuntimeStrategyStats;
+auto WsStrategy::getFactory() -> std::function<WsStrategy*(Runtime&)> {
+ static std::function<WsStrategy*(Runtime&)> factory = [](Runtime& runtime) {
+ return new WsStrategy(runtime);
+ };
+ return factory;
+}
+
WsStrategy::WsStrategy(Runtime& runtime)
: AbstractWorkStealingStrategy(runtime), scheduler(runtime, *this), dispatcher(runtime) {}
diff --git a/emper/strategies/ws/WsStrategy.hpp b/emper/strategies/ws/WsStrategy.hpp
index 1a8d701a8a15f65bd7483c14498d9f3e08c72dff..05e27691c0daed66f77f96eca4019223e6412fe5 100644
--- a/emper/strategies/ws/WsStrategy.hpp
+++ b/emper/strategies/ws/WsStrategy.hpp
@@ -2,6 +2,7 @@
// Copyright © 2020-2021 Florian Schmaus
#pragma once
+#include <functional>
#include <memory>
#include "strategies/AbstractWorkStealingStrategy.hpp"
@@ -27,6 +28,8 @@ class WsStrategy final : public AbstractWorkStealingStrategy {
auto getDispatcher() -> WsDispatcher& override;
public:
+ static auto getFactory() -> std::function<WsStrategy*(Runtime&)>;
+
auto getStats() -> std::shared_ptr<RuntimeStrategyStats> override;
friend WsScheduler;
diff --git a/emper/strategies/ws/WsStrategyFactory.cpp b/emper/strategies/ws/WsStrategyFactory.cpp
deleted file mode 100644
index fd5151d0a4c348db32391af98884449c9b97b820..0000000000000000000000000000000000000000
--- a/emper/strategies/ws/WsStrategyFactory.cpp
+++ /dev/null
@@ -1,11 +0,0 @@
-// SPDX-License-Identifier: LGPL-3.0-or-later
-// Copyright © 2021 Florian Schmaus
-#include "strategies/ws/WsStrategyFactory.hpp"
-
-class Runtime;
-
-WsStrategyFactory WsStrategyFactory::INSTANCE;
-
-auto WsStrategyFactory::constructRuntimeStrategy(Runtime& runtime) -> WsStrategy* {
- return new WsStrategy(runtime);
-}
diff --git a/emper/strategies/ws/WsStrategyFactory.hpp b/emper/strategies/ws/WsStrategyFactory.hpp
deleted file mode 100644
index a3c7d04cd7db5b50816d2d0ad390b4f724decbe1..0000000000000000000000000000000000000000
--- a/emper/strategies/ws/WsStrategyFactory.hpp
+++ /dev/null
@@ -1,15 +0,0 @@
-// SPDX-License-Identifier: LGPL-3.0-or-later
-// Copyright © 2021 Florian Schmaus
-#pragma once
-
-#include "RuntimeStrategyFactory.hpp"
-#include "strategies/ws/WsStrategy.hpp"
-
-class Runtime;
-
-class WsStrategyFactory : public RuntimeStrategyFactory {
- public:
- auto constructRuntimeStrategy(Runtime& runtime) -> WsStrategy* override;
-
- static WsStrategyFactory INSTANCE;
-};
diff --git a/emper/strategies/ws/meson.build b/emper/strategies/ws/meson.build
index 3cc10e2e4d5eb857c0237e57d39736a24e7a5ff7..6554bc5aa9dd7f0dc2df339515d2906a08ff5f74 100644
--- a/emper/strategies/ws/meson.build
+++ b/emper/strategies/ws/meson.build
@@ -1,6 +1,5 @@
emper_cpp_sources += files(
'WsStrategy.cpp',
- 'WsStrategyFactory.cpp',
'WsStrategyStats.cpp',
'WsScheduler.cpp',
'WsDispatcher.cpp',
diff --git a/eval/Locality.cpp b/eval/Locality.cpp
index 67bb4149f92bfecfc6d61464e5e92e6dbc90d8f8..b023cc326c5be14dd74b45c2775ce8de8a5493fd 100644
--- a/eval/Locality.cpp
+++ b/eval/Locality.cpp
@@ -1,23 +1,24 @@
// SPDX-License-Identifier: LGPL-3.0-or-later
-// Copyright © 2020-2021 Florian Schmaus
+// Copyright © 2020-2022 Florian Schmaus
#include <unistd.h> // for getopt, optarg
-#include <algorithm> // for generate
-#include <chrono> // for microseconds, high_resol...
-#include <cstdint> // for uint8_t, UINT8_MAX
-#include <cstdlib> // for abort, exit, EXIT_SUCCESS
-#include <iostream> // for operator<<, basic_ostream
-#include <random> // for mt19937, uniform_int_dis...
-#include <string> // for string, operator<<, oper...
-
-#include "CountingPrivateSemaphore.hpp" // for CPS
-#include "Debug.hpp" // for DBG
-#include "Fiber.hpp" // for Fiber, Fiber::NOT_AFFINE
-#include "PrivateSemaphore.hpp" // for PS
-#include "Runtime.hpp" // for Runtime
-#include "emper-common.h" // for workeraffinity_t, UNUSED...
-#include "lib/DebugUtil.hpp" // for enableStacktraceOnAborts
-#include "strategies/laws/LawsStrategyFactory.hpp" // for LawsStrategy, LawsStrate...
+#include <algorithm>
+#include <chrono>
+#include <cstdint>
+#include <cstdlib>
+#include <functional>
+#include <iostream>
+#include <random>
+#include <string>
+
+#include "CountingPrivateSemaphore.hpp" // for CPS
+#include "Debug.hpp" // for DBG
+#include "Fiber.hpp" // for Fiber, Fiber::NOT_AFFINE
+#include "PrivateSemaphore.hpp" // for PS
+#include "Runtime.hpp" // for Runtime
+#include "emper-common.h" // for workeraffinity_t, UNUSED...
+#include "lib/DebugUtil.hpp" // for enableStacktraceOnAborts
+#include "strategies/laws/LawsStrategy.hpp"
#define L1_CACHE_LINE_SIZE 64 // 64 Bytes
@@ -255,7 +256,7 @@ auto main(UNUSED_ARG int argc, UNUSED_ARG char* argv[]) -> int {
runtime = new Runtime();
break;
case wslh:
- runtime = new Runtime(LawsStrategyFactory::INSTANCE);
+ runtime = new Runtime(LawsStrategy::getFactory());
break;
}
diff --git a/tests/SimpleLawsTest.cpp b/tests/SimpleLawsTest.cpp
index 1aea69c93f1e9dc117d9f6c66fa092aa25923fc8..47c87fe2addc515d24d10dc0ad39bba2853f29d9 100644
--- a/tests/SimpleLawsTest.cpp
+++ b/tests/SimpleLawsTest.cpp
@@ -1,12 +1,13 @@
// SPDX-License-Identifier: LGPL-3.0-or-later
-// Copyright © 2020-2021 Florian Schmaus
+// Copyright © 2020-2022 Florian Schmaus
#include <array>
-#include <atomic> // for atomic, __atomic_base
-#include <cstdint> // for uint64_t, UINT64_MAX
-#include <cstdlib> // for free, exit, EXIT_FAILURE
-#include <cstring> // for memset
-#include <iostream> // for operator<<, endl, basic_...
-#include <random> // for mt19937_64, random_device
+#include <atomic>
+#include <cstdint>
+#include <cstdlib>
+#include <cstring>
+#include <functional>
+#include <iostream>
+#include <random>
#include "Common.hpp" // for ALIGN_TO_CACHE_LINE
#include "CountingPrivateSemaphore.hpp" // for CPS
@@ -14,12 +15,10 @@
#include "Runtime.hpp" // for Runtime
#include "emper-common.h" // for UNUSED_ARG, workeraffini...
#include "lib/template_util.hpp"
-#include "strategies/laws/LawsStrategyFactory.hpp"
+#include "strategies/laws/LawsStrategy.hpp"
namespace tu = emper::lib::template_util;
-class RuntimeStrategyFactory;
-
static const unsigned int ROUND_COUNT = 10;
static const unsigned int FIBER_LOOPS = 10;
static const unsigned int PAYLOAD_COUNT = 4096;
@@ -108,8 +107,7 @@ static void alphaFun() {
}
auto main(UNUSED_ARG int args, UNUSED_ARG char* argv[]) -> int {
- RuntimeStrategyFactory& lawsStrategyFactory = LawsStrategyFactory::INSTANCE;
- Runtime runtime(lawsStrategyFactory);
+ Runtime runtime(LawsStrategy::getFactory());
Fiber* alphaFiber = Fiber::from(&alphaFun);