Remove Raul::Slave class.

Merge Thread::stop() and Thread::join().
Clean thread shut down without the use of pthread_cancel().


git-svn-id: http://svn.drobilla.net/lad/trunk/ingen@4708 a436a847-0d15-0410-975c-d299462d15a1

1 files changed, 18 insertions, 13 deletions

diff --git a/src/gui/ThreadedLoader.cpp b/src/gui/ThreadedLoader.cpp
index f7c77c99..a6c9b1ed 100644
--- a/src/gui/ThreadedLoader.cpp
+++ b/src/gui/ThreadedLoader.cpp
@@ -32,8 +32,9 @@ namespace Ingen {
 namespace GUI {
 
 ThreadedLoader::ThreadedLoader(App& app, SharedPtr<Interface> engine)
-	: Raul::Slave("Loader")
+	: Raul::Thread("Loader")
 	, _app(app)
+	, _sem(0)
 	, _engine(engine)
 {
 	if (parser())
@@ -42,6 +43,12 @@ ThreadedLoader::ThreadedLoader(App& app, SharedPtr<Interface> engine)
 		warn << "Failed to load ingen_serialisation module, load disabled." << endl;
 }
 
+ThreadedLoader::~ThreadedLoader()
+{
+	_exit_flag = true;
+	_sem.post();
+}
+
 SharedPtr<Serialisation::Parser>
 ThreadedLoader::parser()
 {
@@ -54,16 +61,16 @@ ThreadedLoader::parser()
 }
 
 void
-ThreadedLoader::_whipped()
+ThreadedLoader::_run()
 {
-	_mutex.lock();
-
-	while ( ! _events.empty() ) {
-		_events.front()();
-		_events.pop_front();
+	while (_sem.wait() && !_exit_flag) {
+		_mutex.lock();
+		while (!_events.empty()) {
+			_events.front()();
+			_events.pop_front();
+		}
+		_mutex.unlock();
 	}
-
-	_mutex.unlock();
 }
 
 void
@@ -96,9 +103,8 @@ ThreadedLoader::load_patch(bool                              merge,
 			           engine_symbol,
 			           engine_data)));
 
-	whip();
-
 	_mutex.unlock();
+	_sem.post();
 }
 
 void
@@ -112,8 +118,7 @@ ThreadedLoader::save_patch(SharedPtr<const Client::PatchModel> model,
 		model, filename)));
 
 	_mutex.unlock();
-
-	whip();
+	_sem.post();
 }
 
 void