Oops, forgot this

ext/native/thread/prioritizedworkqueue.cpp

@@ -32,6 +32,23 @@ void PrioritizedWorkQueue::Flush() {
 	queue_.clear();
 }
 
+void PrioritizedWorkQueue::WaitUntilDone() {
+	if (queue_.empty())
+		return;
+	// This could be made more elegant..
+	while (true) {
+		bool empty;
+		{
+			lock_guard guard(mutex_);
+			empty = queue_.empty();
+		}
+		if (empty) {
+			break;
+		}
+		sleep_ms(10);
+	}
+}
+
 
 // The worker should simply call this in a loop. Will block when appropriate.
 PrioritizedWorkQueueItem *PrioritizedWorkQueue::Pop() {

ext/native/thread/prioritizedworkqueue.h

@@ -34,6 +34,7 @@ public:
 	void Flush();
 	bool Done() { return done_; }
 	void Stop();
+	void WaitUntilDone();
 
 private:
 	bool done_;