Welcome to mirror list, hosted at ThFree Co, Russian Federation.

git.blender.org/blender.git - Unnamed repository; edit this file 'description' to name the repository.
summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
Diffstat (limited to 'extern/audaspace/src/devices/ThreadedDevice.cpp')
-rw-r--r--extern/audaspace/src/devices/ThreadedDevice.cpp65
1 files changed, 65 insertions, 0 deletions
diff --git a/extern/audaspace/src/devices/ThreadedDevice.cpp b/extern/audaspace/src/devices/ThreadedDevice.cpp
new file mode 100644
index 00000000000..44ceccb8a60
--- /dev/null
+++ b/extern/audaspace/src/devices/ThreadedDevice.cpp
@@ -0,0 +1,65 @@
+/*******************************************************************************
+ * Copyright 2009-2016 Jörg Müller
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ ******************************************************************************/
+
+#include "devices/ThreadedDevice.h"
+
+#include <mutex>
+
+AUD_NAMESPACE_BEGIN
+
+void ThreadedDevice::start()
+{
+ std::lock_guard<ILockable> lock(*this);
+
+ // thread is still running, we can abort stopping it
+ if(m_stop)
+ m_stop = false;
+
+ // thread is not running, let's start it
+ else if(!m_playing)
+ {
+ if(m_thread.joinable())
+ m_thread.join();
+
+ m_playing = true;
+
+ m_thread = std::thread(&ThreadedDevice::runMixingThread, this);
+ }
+}
+
+void ThreadedDevice::playing(bool playing)
+{
+ if((!m_playing || m_stop) && playing)
+ start();
+ else
+ m_stop = true;
+}
+
+ThreadedDevice::ThreadedDevice() :
+ m_playing(false),
+ m_stop(false)
+{
+}
+
+void aud::ThreadedDevice::stopMixingThread()
+{
+ stopAll();
+
+ if(m_thread.joinable())
+ m_thread.join();
+}
+
+AUD_NAMESPACE_END