AsyncNonBlockingStore can have many more modifications than modification queue size ----------------------------------------------------------------------------------- Key: ISPN-12430 URL: https://issues.redhat.com/browse/ISPN-12430 Project: Infinispan Issue Type: Bug Components: Loaders and Stores Reporter: Will Burns Assignee: Will Burns Priority: Major Fix For: 12.0.0.Final The AsyncNonBlockingStore is known to allow for concurrent writes more than modification queue size. Unfortunately, due to how synchronized Publisher works it can be much much more if a given thread is delayed as other threads can sneak in. For example in the stress test with 1024 modification queue size I could get 6K entries in a given queue. The problem is that the concurrent publisher would add the value to its own queue which was only processed on the first thread, which means many could sneak in as no changes were actually populated in the map. https://github.com/ReactiveX/RxJava/blob/3.x/src/main/java/io/reactivex/r... We should change this to be a bit more strict and limit the writes to only queue + # of threads with concurrent modifications.