Actually use the LawsMpscQueue typedef

emper/strategies/laws/LawsScheduler.cpp

@@ -7,7 +7,7 @@
 
 #define EMPER_OVERFLOW_QUEUE
 
-thread_local adt::MpscQueue<Fiber> LawsScheduler::priorityQueue;
+thread_local LawsScheduler::LawsMpscQueue LawsScheduler::priorityQueue;
 
 thread_local LawsScheduler::WsQueue<LawsScheduler::QUEUE_SIZE> LawsScheduler::queue;
 
@@ -15,7 +15,7 @@ LawsScheduler::LawsScheduler(Runtime& runtime, LawsStrategy& lawsStrategy) : Sch
 																		   , lawsStrategy(lawsStrategy) {
 	const workerid_t workerCount = runtime.getWorkerCount();
 	queues = new LawsScheduler::WsQueue<QUEUE_SIZE>*[workerCount];
-	priorityQueues = new adt::MpscQueue<Fiber>*[workerCount];
+	priorityQueues = new LawsScheduler::LawsMpscQueue*[workerCount];
 	mainThreadQueue = &queue;
 
 	auto newWorkerHook = [this]() {

emper/strategies/laws/LawsScheduler.hpp

@@ -30,11 +30,11 @@ public:
 	static const int QUEUE_SIZE = 1024;
 
 private:
-	adt::MpscQueue<Fiber>** priorityQueues;
+	LawsMpscQueue** priorityQueues;
 
 	WsQueue<QUEUE_SIZE>** queues;
 
-	static thread_local adt::MpscQueue<Fiber> priorityQueue;
+	static thread_local LawsMpscQueue priorityQueue;
 
 	static thread_local LawsScheduler::WsQueue<QUEUE_SIZE> queue;