Browse Source

Use write locks for write guards instead of read locks.

Closes #4665
issue/4755
Mark Paluch 2 years ago
parent
commit
2c946a1074
No known key found for this signature in database
GPG Key ID: 55BC6374BAA9D973
  1. 4
      spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/messaging/DefaultMessageListenerContainer.java

4
spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/messaging/DefaultMessageListenerContainer.java

@ -55,11 +55,11 @@ public class DefaultMessageListenerContainer implements MessageListenerContainer @@ -55,11 +55,11 @@ public class DefaultMessageListenerContainer implements MessageListenerContainer
private final ReadWriteLock lifecycleMonitor = new ReentrantReadWriteLock();
private final Lock lifecycleRead = Lock.of(lifecycleMonitor.readLock());
private final Lock lifecycleWrite = Lock.of(lifecycleMonitor.readLock());
private final Lock lifecycleWrite = Lock.of(lifecycleMonitor.writeLock());
private final ReadWriteLock subscriptionMonitor = new ReentrantReadWriteLock();
private final Lock subscriptionRead = Lock.of(subscriptionMonitor.readLock());
private final Lock subscriptionWrite = Lock.of(subscriptionMonitor.readLock());
private final Lock subscriptionWrite = Lock.of(subscriptionMonitor.writeLock());
private boolean running = false;

Loading…
Cancel
Save