5 Replies Latest reply on Feb 9, 2017 10:15 AM by rvansa

    Cache loading barrier

    diuis
    diuis Feb 9, 2017 1:57 AM

      Hi!

      Do you know if Infinispan (with the hotrod remote client) supports with the JCache API something like a cache barrier when I try to put in the cache a value from two threads but with the same key?

      Like the EHCache barrier of EHCache, or the atomically cache loading of Guava.

       

      Thanxs,

      Demis

      • 179 Views
      • Tags:
        • 1. Re: Cache loading barrier
          nadirx
          nadirx Feb 9, 2017 2:18 AM (in response to diuis)

          Infinispan implements the semantics of the JDK ConcurrentHashMap. It seems to me like what you want is putIfAbsent which is present in both RemoteCache and in JCache.

            • Actions
          • 2. Re: Cache loading barrier
            diuis
            diuis Feb 9, 2017 3:50 AM (in response to nadirx)

            Hi Tristan,

            what I need is a little different.

            I want to invoke the get(String key) method on the javax.cache.Cache interface (configured with setReadThrough(true) and use a custom CacheLoader<String, String>) from two (or more) different concurrent threads for a key not already cached.

            When the first thread invokes the load(String key) method on my CacheLoader (configured with setCacheLoaderFactory(new FactoryBuilder.SingletonFactory<CacheLoader<String, String>>(new JCacheCacheLoader())) I want the others threads blocked on the javax.cache.get() method, waiting for the result retrieved from the first CacheLoader.

            This because the operation to retrieve the cache value on the CacheLoader is very expansive, and the result will be the same for the same key.

            Is it possibile not to execute the others CacheLoader if the first returns correctly?

              • Actions
            • 3. Re: Cache loading barrier
              rvansa
              rvansa Feb 9, 2017 4:09 AM (in response to diuis)

              No, such feature is not natively available, it's tracked as [ISPN-7224] Support synchronous get in Spring's cache abstraction Currently the closest thing you can do is pessimistic transactional cache and issue the read with cache.withFlags(Flag.FORCE_WRITE_LOCK).get(key).

                • Actions
              • 4. Re: Cache loading barrier
                diuis
                diuis Feb 9, 2017 4:46 AM (in response to rvansa)

                Hi Radim!

                Thank you for your response,

                The only way to enable the pessimistic transactional cache is to reconfigure the cache on the remote server?

                Is it possible to set the FORCE_WITH_LOCK flag with the JCache API?

                  • Actions
                • 5. Re: Cache loading barrier
                  rvansa
                  rvansa Feb 9, 2017 10:15 AM (in response to diuis)

                  Regrettably not, not with JCache, and not even if you're using Hot Rod or REST (as you speak about remote server).

                   

                  Actually I think that implementing that would be a doable for a new contributor; the changes could be isolated to single interceptor/extending the current CacheLoaderInterceptor.

                    • Actions