CacheTest.java

/*
 * Copyright 2014 LinkedIn Corp.
 *
 * Licensed under the Apache License, Version 2.0 (the "License"); you may not
 * use this file except in compliance with the License. You may obtain a copy of
 * the License at
 *
 * http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
 * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
 * License for the specific language governing permissions and limitations under
 * the License.
 */

package azkaban.utils.cache;

import org.junit.Assert;
import org.junit.Test;

import azkaban.utils.cache.Cache.EjectionPolicy;

public class CacheTest {
  @Test
  public void testLRU() {
    CacheManager manager = CacheManager.getInstance();
    Cache cache = manager.createCache();
    cache.setEjectionPolicy(EjectionPolicy.LRU);
    cache.setMaxCacheSize(4);

    cache.insertElement("key1", "val1");
    cache.insertElement("key2", "val2");
    cache.insertElement("key3", "val3");
    cache.insertElement("key4", "val4");

    Assert.assertEquals(cache.get(String.class, "key2"), "val2");
    Assert.assertEquals(cache.get(String.class, "key3"), "val3");
    Assert.assertEquals(cache.get(String.class, "key4"), "val4");
    Assert.assertEquals(cache.get(String.class, "key1"), "val1");
    Assert.assertEquals(4, cache.getSize());

    cache.insertElement("key5", "val5");
    Assert.assertEquals(4, cache.getSize());
    Assert.assertEquals(cache.get(String.class, "key3"), "val3");
    Assert.assertEquals(cache.get(String.class, "key4"), "val4");
    Assert.assertEquals(cache.get(String.class, "key1"), "val1");
    Assert.assertEquals(cache.get(String.class, "key5"), "val5");
    Assert.assertNull(cache.get(String.class, "key2"));
  }

  @Test
  public void testFIFO() {
    CacheManager manager = CacheManager.getInstance();
    Cache cache = manager.createCache();
    cache.setEjectionPolicy(EjectionPolicy.FIFO);
    cache.setMaxCacheSize(4);

    cache.insertElement("key1", "val1");
    synchronized (this) {
      try {
        wait(10);
      } catch (InterruptedException e) {
      }
    }
    cache.insertElement("key2", "val2");
    cache.insertElement("key3", "val3");
    cache.insertElement("key4", "val4");

    Assert.assertEquals(cache.get(String.class, "key2"), "val2");
    Assert.assertEquals(cache.get(String.class, "key3"), "val3");
    Assert.assertEquals(cache.get(String.class, "key4"), "val4");
    Assert.assertEquals(cache.get(String.class, "key1"), "val1");
    Assert.assertEquals(4, cache.getSize());

    cache.insertElement("key5", "val5");
    Assert.assertEquals(4, cache.getSize());
    Assert.assertEquals(cache.get(String.class, "key3"), "val3");
    Assert.assertEquals(cache.get(String.class, "key4"), "val4");
    Assert.assertEquals(cache.get(String.class, "key2"), "val2");
    Assert.assertEquals(cache.get(String.class, "key5"), "val5");
    Assert.assertNull(cache.get(String.class, "key1"));
  }

  @Test
  public void testTimeToLiveExpiry() {
    CacheManager.setUpdateFrequency(200);
    CacheManager manager = CacheManager.getInstance();
    Cache cache = manager.createCache();

    cache.setUpdateFrequencyMs(200);
    cache.setEjectionPolicy(EjectionPolicy.FIFO);
    cache.setExpiryTimeToLiveMs(4500);
    cache.insertElement("key1", "val1");

    synchronized (this) {
      try {
        wait(1000);
      } catch (InterruptedException e) {
      }
    }
    Assert.assertEquals(cache.get(String.class, "key1"), "val1");
    cache.insertElement("key2", "val2");
    synchronized (this) {
      try {
        wait(4000);
      } catch (InterruptedException e) {
      }
    }
    Assert.assertNull(cache.get(String.class, "key1"));
    Assert.assertEquals("val2", cache.get(String.class, "key2"));

    synchronized (this) {
      try {
        wait(1000);
      } catch (InterruptedException e) {
      }
    }

    Assert.assertNull(cache.get(String.class, "key2"));
  }

  @Test
  public void testIdleExpireExpiry() {
    CacheManager.setUpdateFrequency(250);
    CacheManager manager = CacheManager.getInstance();
    Cache cache = manager.createCache();

    cache.setUpdateFrequencyMs(250);
    cache.setEjectionPolicy(EjectionPolicy.FIFO);
    cache.setExpiryIdleTimeMs(4500);
    cache.insertElement("key1", "val1");
    cache.insertElement("key3", "val3");
    synchronized (this) {
      try {
        wait(1000);
      } catch (InterruptedException e) {
      }
    }
    Assert.assertEquals(cache.get(String.class, "key1"), "val1");
    cache.insertElement("key2", "val2");
    synchronized (this) {
      try {
        wait(4000);
      } catch (InterruptedException e) {
      }
    }
    Assert.assertEquals("val1", cache.get(String.class, "key1"));
    Assert.assertNull(cache.get(String.class, "key3"));
    synchronized (this) {
      try {
        wait(1000);
      } catch (InterruptedException e) {
      }
    }

    Assert.assertNull(cache.get(String.class, "key2"));
  }
}