Another macOS std::list boost::thread SNAFU.

2 files changed, 7 insertions, 5 deletions

diff --git a/src/lib/encode_server.cc b/src/lib/encode_server.cc
index e79f82b62..5884df09a 100644
--- a/src/lib/encode_server.cc
+++ b/src/lib/encode_server.cc
@@ -87,12 +87,13 @@ EncodeServer::~EncodeServer ()
 		_full_condition.notify_all ();
 	}
 
-	BOOST_FOREACH (boost::thread& i, _worker_threads) {
+	BOOST_FOREACH (boost::thread* i, _worker_threads) {
 		try {
-			i.join ();
+			i->join ();
 		} catch (...) {
 
 		}
+		delete i;
 	}
 
 	{
@@ -233,9 +234,10 @@ EncodeServer::run ()
 	}
 
 	for (int i = 0; i < _num_threads; ++i) {
-		_worker_threads.push_back (thread(bind(&EncodeServer::worker_thread, this)));
+		boost::thread* t = new thread(bind(&EncodeServer::worker_thread, this));
+		_worker_threads.push_back (t);
 #ifdef DCPOMATIC_LINUX
-		pthread_setname_np (_worker_threads.back().native_handle(), "encode-server-worker");
+		pthread_setname_np (t->native_handle(), "encode-server-worker");
 #endif
 	}
 
diff --git a/src/lib/encode_server.h b/src/lib/encode_server.h
index 40e84ad60..91e007503 100644
--- a/src/lib/encode_server.h
+++ b/src/lib/encode_server.h
@@ -54,7 +54,7 @@ private:
 	void broadcast_thread ();
 	void broadcast_received ();
 
-	std::vector<boost::thread> _worker_threads;
+	std::vector<boost::thread*> _worker_threads;
 	std::list<boost::shared_ptr<Socket> > _queue;
 	boost::condition _full_condition;
 	boost::condition _empty_condition;