Actually "turning off" all threads.

dhermes · dhermes · commit c377b3cc88f9 · 2017-12-06T15:28:27.000-08:00
diff --git a/pubsub/google/cloud/pubsub_v1/subscriber/policy/thread.py b/pubsub/google/cloud/pubsub_v1/subscriber/policy/thread.py
@@ -151,7 +151,10 @@ def close(self):
         # Stop consuming messages.
         self._request_queue.put(_helper_threads.STOP)
         self._dispatch_thread.join()  # Wait until stopped.
+        self._dispatch_thread = None
         self._consumer.stop_consuming()
+        self._leases_thread.join()
+        self._leases_thread = None
         self._executor.shutdown()
 
         # The subscription is closing cleanly; resolve the future if it is not
