diff --git a/google-cloud-spanner/src/main/java/com/google/cloud/spanner/MultiplexedSessionDatabaseClient.java b/google-cloud-spanner/src/main/java/com/google/cloud/spanner/MultiplexedSessionDatabaseClient.java index d4fc3c6d75..867786be84 100644 --- a/google-cloud-spanner/src/main/java/com/google/cloud/spanner/MultiplexedSessionDatabaseClient.java +++ b/google-cloud-spanner/src/main/java/com/google/cloud/spanner/MultiplexedSessionDatabaseClient.java @@ -562,7 +562,7 @@ final class MultiplexedSessionMaintainer { this.clock = clock; } - void start() { + private synchronized void start() { // Schedule the maintainer to run once every ten minutes (by default). long loopFrequencyMillis = MultiplexedSessionDatabaseClient.this @@ -577,7 +577,7 @@ void start() { this::maintain, loopFrequencyMillis, loopFrequencyMillis, TimeUnit.MILLISECONDS); } - void stop() { + private synchronized void stop() { if (this.scheduledFuture != null) { this.scheduledFuture.cancel(false); }