mizie
diff --git a/‎google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/spi/v1/PollingSubscriberConnection.java‎
Lines changed: 6 additions & 1 deletion b/‎google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/spi/v1/PollingSubscriberConnection.java‎
Lines changed: 6 additions & 1 deletion
@@ -127,6 +127,9 @@ protected void doStop() {
   }
 
   private void pullMessages(final Duration backoff) {
+    if (!isAlive()) {
+      return;
+    }
     ListenableFuture<PullResponse> pullResult =
         stub.withDeadlineAfter(DEFAULT_TIMEOUT.toMillis(), TimeUnit.MILLISECONDS)
             .pull(
@@ -201,7 +204,9 @@ public void run() {
   }
 
   private boolean isAlive() {
-    return state() == State.RUNNING || state() == State.STARTING;
+    // Read state only once. Because of threading, different calls can give different results.
+    State state = state();
+    return state == State.RUNNING || state == State.STARTING;
   }
 
   @Override
Original file line number	Diff line number	Diff line change
`@@ -127,6 +127,9 @@ protected void doStop() {`
`127`	`127`	`}`
`128`	`128`
`129`	`129`	`private void pullMessages(final Duration backoff) {`
	`130`	`+ if (!isAlive()) {`
	`131`	`+ return;`
	`132`	`+ }`
`130`	`133`	`ListenableFuture<PullResponse> pullResult =`
`131`	`134`	`stub.withDeadlineAfter(DEFAULT_TIMEOUT.toMillis(), TimeUnit.MILLISECONDS)`
`132`	`135`	`.pull(`
`@@ -201,7 +204,9 @@ public void run() {`
`201`	`204`	`}`
`202`	`205`
`203`	`206`	`private boolean isAlive() {`
`204`		`- return state() == State.RUNNING \|\| state() == State.STARTING;`
	`207`	`+ // Read state only once. Because of threading, different calls can give different results.`
	`208`	`+ State state = state();`
	`209`	`+ return state == State.RUNNING \|\| state == State.STARTING;`
`205`	`210`	`}`
`206`	`211`
`207`	`212`	`@Override`