[jboss-cvs] JBossCache/src/org/jboss/cache/interceptors ...

[Manik Surtani]

  User: msurtani
  Date: 07/06/18 17:42:20

  Modified:    src/org/jboss/cache/interceptors 
                        BaseCacheLoaderInterceptor.java
  Log:
  Experiment with cache loader thread safety
  
  Revision  Changes    Path
  1.10      +8 -1      JBossCache/src/org/jboss/cache/interceptors/BaseCacheLoaderInterceptor.java
  
  (In the diff below, changes in quantity of whitespace are not shown.)
  
  Index: BaseCacheLoaderInterceptor.java
  ===================================================================
  RCS file: /cvsroot/jboss/JBossCache/src/org/jboss/cache/interceptors/BaseCacheLoaderInterceptor.java,v
  retrieving revision 1.9
  retrieving revision 1.10
  diff -u -b -r1.9 -r1.10
  --- BaseCacheLoaderInterceptor.java	19 Mar 2007 19:03:34 -0000	1.9
  +++ BaseCacheLoaderInterceptor.java	18 Jun 2007 21:42:20 -0000	1.10
  @@ -9,7 +9,6 @@
   import org.jboss.cache.CacheSPI;
   import org.jboss.cache.loader.CacheLoader;
   
  -import java.util.ConcurrentModificationException;
   import java.util.List;
   import java.util.Map;
   import java.util.concurrent.ConcurrentHashMap;
  @@ -37,6 +36,7 @@
       */
      protected void obtainLoaderLock(Object lock) throws InterruptedException
      {
  +/*
         Thread current = Thread.currentThread();
   
         synchronized (this)
  @@ -54,6 +54,7 @@
   
            lockMap.put(lock, current);
         }
  +*/
      }
   
      /**
  @@ -61,26 +62,32 @@
       */
      protected void releaseLoaderLock(Object lock)
      {
  +/*
         synchronized (this)
         {
            lockMap.remove(lock);
            this.notify();
         }
  +*/
      }
   
      protected void releaseLoaderLocks(List locks)
      {
  +/*
         for (Object lock : locks)
         {
            releaseLoaderLock(lock);
         }
  +*/
      }
   
      protected void obtainLoaderLocks(List locks) throws InterruptedException
      {
  +/*
         for (Object lock : locks)
         {
            obtainLoaderLock(lock);
         }
  +*/
      }
   }