Examples of org.hibernate.cache.infinispan.access.PutFromLoadValidator.invalidateRegion()

org.hibernate.cache.infinispan.access.PutFromLoadValidator.invalidateRegion()

Invalidates all {@link #registerPendingPut(Object) previously registered pending puts} ensuring a subsequent call to{@link #acquirePutFromLoadLock(Object)} will return false.

This method will block until anyconcurrent thread that has {@link #acquirePutFromLoadLock(Object) acquired the putFromLoad lock} for the any key hasreleased the lock. This allows the caller to be certain the putFromLoad will not execute after this method returns, possibly caching stale data.

@return true if the invalidation was successful; false if a problem occured (which thecaller should treat as an exception condition)

            ExecutorService executor = Executors.newFixedThreadPool(3);


            // Start with a removal so the "isPutValid" calls will fail if
            // any of the concurrent activity isn't handled properly


            testee.invalidateRegion();


            // Do the registration + isPutValid calls
            executor.execute(r);
            executor.execute(r);
            executor.execute(r);

               public Void call() throws Exception {
                  removeLatch.await();
                  if (keyOnly) {
                     testee.invalidateKey(KEY1);
                  } else {
                     testee.invalidateRegion();
                  }
                  cache.set(null);
                  return null;
               }
            };

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.