diff --git a/lib/include/srslte/common/block_queue.h b/lib/include/srslte/common/block_queue.h
index 2b81f6a14..241ffb52a 100644
--- a/lib/include/srslte/common/block_queue.h
+++ b/lib/include/srslte/common/block_queue.h
@@ -173,9 +173,11 @@ private:
           pthread_cond_wait(&cv_full, &mutex);
         }
         if (!enable) {
+          num_threads--;
           return false;
         }
       } else if (q.size() >= (uint32_t) capacity) {
+        num_threads--;
         return false;
       }
     }