/*

 * Created on Aug 3, 2004

 *

 * To change the template for this generated file go to

 * Window - Preferences - Java - Code Generation - Code and Comments

 */

package de.laures.cewolf.storage;

import java.util.Calendar;

import java.util.Collection;

import java.util.Date;

import java.util.GregorianCalendar;

import java.util.HashMap;

import java.util.Iterator;

import java.util.Map;

/**

 * @author brianf

 * 

 * To change the template for this generated type comment go to Window -

 * Preferences - Java - Code Generation - Code and Comments

 */

public class SessionStorageGroup implements Runnable

{

  private Map map = new HashMap();

  Thread      runner;

  private void start()

  {

    if ( runner == null || !runner.isAlive() )

    {

      runner = new Thread(this);

      runner.setDaemon(false);

      runner.setName("SessionCleanup");

      runner.setPriority(Thread.MIN_PRIORITY);

      runner.start();

    }

  }

  public synchronized Object get( Object a )

  {

    return map.get(a);

  }

  public synchronized Object put( Object a, Object b )

  {

    Object c = map.put(a, b);

    start();

    return c;

  }

  public synchronized Object remove( Object a )

  {

    return map.remove(a);

  }

  /*

   * (non-Javadoc)

   * 

   * @see java.lang.Runnable#run()

   */

  public void run()

  {

    while ( !map.isEmpty() )

    {

      Date date = new Date();

      synchronized (this)

      {

        Collection keys = map.keySet();

        Iterator iter = keys.iterator();

        while ( iter.hasNext() )

        {

          // System.out.println("Get Next");

          String cid = (String) iter.next();

          SessionStorageItem ssi = (SessionStorageItem) get(cid);

          if ( ssi.isExpired(date) )

          {

           // System.out.println("Removing " + ssi);

            iter.remove();

          }

        }

      }

      try

      {

        //System.gc();

        Thread.sleep(1000);

      }

      catch (InterruptedException e)

      {

        // TODO Auto-generated catch block

        e.printStackTrace();

      }

    }

   // System.out.println("Exiting Thread");   

  }

  public static void main( String[] args )

  {

    int start = 0;

   while(true)

    {

      System.out.println("Adding Objects");

    testThread(start);

    try

    {

      Thread.sleep(10000);

    }

    catch (InterruptedException e)

    {

      // TODO Auto-generated catch block

      e.printStackTrace();

    }

    }

  }

  public static void testThread(int start)

  {

    SessionStorageGroup ssg = new SessionStorageGroup();

    Calendar cal = new GregorianCalendar();

    cal.setTime(new Date());

    //   some huge garbage string

    for (int i = start; i < start+10000; i++)

    {

      cal.add(Calendar.MILLISECOND, 1);

      SessionStorageItem ssi = new SessionStorageItem(null, Integer.toString(i), cal.getTime());

      ssg.put(Integer.toString(i), ssi);

    }

  }

  /**

   * Test that memory is freed up when low on it...

   */

  public static void testSoftreferenceMemoryFreeup()

  {

    Date neverexpire = new Date(10000, 1, 1);

    SessionStorageGroup ssg = new SessionStorageGroup();

    //   some huge garbage string

    StringBuffer longString = new StringBuffer();

    for (int i = 0; i < 10000; i++)

    {

      longString.append(Math.random());

    }

    int i = 0;

    long minmem = Long.MAX_VALUE;

    while ( true )

    {

      //   let's use the id string to waste memory

      String key = Long.toString(System.currentTimeMillis());

      String id = key + longString;

      SessionStorageItem ssi = new SessionStorageItem(null, id, neverexpire);

      ssg.put(key, ssi);

      i++;

      long freemem = Runtime.getRuntime().freeMemory();

      long usedmem = Runtime.getRuntime().totalMemory();

      long maxmem = Runtime.getRuntime().maxMemory();

      if ( freemem < minmem )

      {

        minmem = freemem;

      }

      if ( i % 100 == 0 )

      {

        System.out.println("#" + i + ", minimum memory:" + minmem + ", freemem:" + freemem

            + ", usedmem:" + usedmem + ", maxmem:" + maxmem);

      }

    }

  }

}