- forgot to add barrier file

git-svn-id: https://openmodelica.org/svn/OpenModelica/trunk@23294 f25d12d1-65f4-0310-ae8a-bbce733d8d8e

SimulationRuntime/cpp/Include/Core/Utils/extension/busywaiting_barrier.hpp

@@ -0,0 +1,66 @@
+/*
+ * busywaitingbarrier.hpp
+ *
+ *  Created on: 03.11.2014
+ *      Author: marcus
+ */
+
+#ifndef BUSYWAITINGBARRIER_HPP_
+#define BUSYWAITINGBARRIER_HPP_
+
+#ifdef USE_BOOST_THREAD
+
+#include <boost/atomic.hpp>
+#include <iostream>
+
+class busywaiting_barrier
+{
+ public:
+    busywaiting_barrier(int counterValueMax) : counterValue(counterValueMax), counterValueRelease(0), ready(true), counterValueMax(counterValueMax) {}
+    ~busywaiting_barrier() {}
+
+    void wait()
+    {
+        //std::cerr << "entering wait function (counterValueMax: " << counterValueMax << ")" << std::endl;
+        while(!ready.load(boost::memory_order_acquire )) {}
+
+        bool reset = (counterValue.fetch_sub(1,boost::memory_order_release ) == 1); //decrement counter value
+        if(reset)
+        {
+            //std::cerr << "ready state set to false (counterValueMax: " << counterValueMax << ")" << std::endl;
+            ready.store(false, boost::memory_order_release );
+        }
+
+        //std::cerr << "counter decremented (counterValueMax: " << counterValueMax << ")" << std::endl;
+
+        while(counterValue.load(boost::memory_order_acquire ) > 0)
+        {
+            //int val = counterValue.load(boost::memory_order_seq_cst );
+            //std::cerr << "waiting because counter value is " << val << " (counterValueMax: " << counterValueMax << ")" << std::endl;
+            //sleep(1);
+        }
+
+        //std::cerr << "leaving wait function (counterValueMax: " << counterValueMax << ")" << std::endl;
+
+        if(counterValueRelease.fetch_add(1,boost::memory_order_release) == counterValueMax-1)
+        {
+            counterValue.store(counterValueMax, boost::memory_order_release);
+            counterValueRelease.store(0, boost::memory_order_release);
+            ready.store(true, boost::memory_order_release );
+
+            //std::cerr << "set ready to true (counterValueMax: " << counterValueMax << ")" << std::endl;
+        }
+
+        while(counterValueRelease.load(boost::memory_order_acquire ) > 0) {}
+    }
+
+ private:
+    boost::atomic<int> counterValue;
+    boost::atomic<int> counterValueRelease;
+    boost::atomic<bool> ready;
+    int counterValueMax;
+};
+
+#endif //USE_BOOST_THREAD
+
+#endif /* BUSYWAITINGBARRIER_HPP_ */