diff --git a/pl/threads.yap b/pl/threads.yap
index 456f8b371..c73991a73 100644
--- a/pl/threads.yap
+++ b/pl/threads.yap
@@ -616,6 +616,10 @@ message_queue_create(Id) :-
 	fail.
 '$do_msg_queue_create'(_).
 
+'$create_thread_mq'(TId) :-
+	recorded('$queue',q(TId,_,_,_,_), R),
+	erase(R),
+	fail.
 '$create_thread_mq'(TId) :-
 	\+ recorded('$queue',q(TId,_,_,_,_), _),
 	'$new_mutex'(Mutex),