Details
-
Bug
-
Resolution: Done
-
Major
-
5.1.0.CR1
Description
Documentation http://docs.jboss.org/infinispan/5.1/apidocs/config.html#ce_loader_async :
"modificationQueueSize int 1024 Sets the size of the modification queue for the async store. If updates are made at a rate that is faster than the underlying cache store can process this queue, then the async store behaves like a synchronous store for that period, blocking until the queue can accept more elements. (Javadoc)"
However the async store doesn't "behaves like synchronous [...] blocking until the queue can accept more elements" because AsyncStore.enqueue() calls
changesDeque.add(mod);
But I guess it should call put() to wait queue to accept more elements.