diff --git a/ext/native/thread/prioritizedworkqueue.cpp b/ext/native/thread/prioritizedworkqueue.cpp
index b10cbe0c4c..9559ead072 100644
--- a/ext/native/thread/prioritizedworkqueue.cpp
+++ b/ext/native/thread/prioritizedworkqueue.cpp
@@ -107,7 +107,9 @@ void ProcessWorkQueueOnThreadWhile(PrioritizedWorkQueue *wq) {
 
 void StopProcessingWorkQueue(PrioritizedWorkQueue *wq) {
 	wq->Stop();
-	workThread->join();
-	delete workThread;
+	if (workThread) {
+		workThread->join();
+		delete workThread;
+	}
 	workThread = 0;
 }