package com.atlassian.cache.memory;
   
   import com.atlassian.cache.AbstractCacheLazyTest;
   
   import com.atlassian.cache.Cache;
   import org.junit.Before;
   import org.junit.Test;
   
   import java.util.concurrent.CountDownLatch;
  import java.util.concurrent.ExecutorService;
  import java.util.concurrent.Executors;
  
  /**
   * Test the Delegated Lazy Cache
   *
   * @since 2.0
   */
  public class DelegatingCacheLazyTest extends AbstractCacheLazyTest
  {
      @Before
      public void setUp() throws Exception
      {
          factory = new MemoryCacheManager();
      }
  
      @Test(timeout = 15000L)
      public void testConcurrentRemovesAndGets() throws Exception
      {
          final int THREADS = 10;
          CountDownLatch latch = new CountDownLatch(THREADS);
          Cache<String, Long> cache = makeSlowCache();
          ExecutorService executorService = Executors.newFixedThreadPool(THREADS);
          for (int i = 0; i < THREADS; i++)
          {
              executorService.submit(() ->
              {
                  cache.remove("42");
                  if (((Long) 42L).equals(cache.get("42")))
                  {
                      latch.countDown();
                  }
              });
          }
          latch.await();
          assertSize(cache, 1);
      }
  
  }